XuMQ::MsgQueueMapper类 参考

消息队列持久化管理类 将数据存储在sqlite数据库中 更多...

#include <queue.hpp>

XuMQ::MsgQueueMapper 的协作图:

Public 成员函数
	MsgQueueMapper (const std::string &dbfile)
	消息队列持久化管理类 构造函数
void	createTable ()
	创建一张表
void	removeTable ()
	移除一张表
bool	insert (MsgQueue::ptr &queue)
	新增一个消息队列
bool	remove (const std::string &name)
	移除一个消息队列
QueueMap	recovery ()
	获取所有消息队列 从数据库加载到内存

静态 Private 成员函数
static int	selectCallback (void *arg, int numcol, char **row, char **fields)
	select语句的回调函数 将获取到的数据存入参数中

Private 属性
SqliteHelper	_sql_helper
	数据库操作对象

详细描述

消息队列持久化管理类 将数据存储在sqlite数据库中

构造及析构函数说明

MsgQueueMapper()

XuMQ::MsgQueueMapper::MsgQueueMapper ( const std::string &  dbfile )

inline

消息队列持久化管理类 构造函数

参数

dbfile

数据库名称

注解

如果数据库不存在则自动创建

函数调用图:

成员函数说明

createTable()

void XuMQ::MsgQueueMapper::createTable ( )

inline

创建一张表

函数调用图:

这是这个函数的调用关系图:

insert()

bool XuMQ::MsgQueueMapper::insert ( MsgQueue::ptr &  queue )

inline

新增一个消息队列

参数

queue

消息队列指针

返回

新增成功返回true 失败返回false并输出日志

函数调用图:

这是这个函数的调用关系图:

recovery()

QueueMap XuMQ::MsgQueueMapper::recovery ( )

inline

获取所有消息队列 从数据库加载到内存

返回

一张映射表 消息队列名称->消息队列指针

参见

MsgQueue::ptr MsgQueueManager

函数调用图:

这是这个函数的调用关系图:

remove()

bool XuMQ::MsgQueueMapper::remove ( const std::string &  name )

inline

移除一个消息队列

参数

name

消息队列名称

返回

删除成功返回true 删除失败输出日志并返回false

函数调用图:

这是这个函数的调用关系图:

removeTable()

void XuMQ::MsgQueueMapper::removeTable ( )

inline

移除一张表

函数调用图:

这是这个函数的调用关系图:

selectCallback()

static int XuMQ::MsgQueueMapper::selectCallback ( void *  arg, int  numcol, char **  row, char **  fields  )

inlinestaticprivate

select语句的回调函数 将获取到的数据存入参数中

参数

arg	存入的参数
numcol	列数
row	行
fields	列名

返回

处理结果 0表示正常退出

这是这个函数的调用关系图:

类成员变量说明

_sql_helper

SqliteHelper XuMQ::MsgQueueMapper::_sql_helper

private

数据库操作对象