XuMQ::ExchangeMapper类 参考

#include <exchange.hpp>

XuMQ::ExchangeMapper 的协作图:

Public 成员函数
	ExchangeMapper (const std::string &dbfile)
	交换机持久化管理类 构造函数
void	createTable ()
	创建一张表
void	removeTable ()
	移除一张表
bool	insert (Exchange::ptr &exchange)
	新增一个交换机
bool	remove (const std::string &name)
	移除一个交换机
ExchangeMap	recovery ()
	获取所有交换机 从数据库加载到内存

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

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

构造及析构函数说明

ExchangeMapper()

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

inline

交换机持久化管理类 构造函数

参数

dbfile

数据库名称

注解

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

函数调用图:

成员函数说明

createTable()

void XuMQ::ExchangeMapper::createTable ( )

inline

创建一张表

函数调用图:

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

insert()

bool XuMQ::ExchangeMapper::insert ( Exchange::ptr &  exchange )

inline

新增一个交换机

参数

exchange

交换机对象指针

参见

Exchange::ptr

返回

插入成功返回true 插入失败输出日志并返回false

函数调用图:

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

recovery()

ExchangeMap XuMQ::ExchangeMapper::recovery ( )

inline

获取所有交换机 从数据库加载到内存

返回

一张映射表 交换机名称->交换机对象指针

参见

Exchange::ptr ExchangeManager

函数调用图:

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

remove()

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

inline

移除一个交换机

参数

name

交换机名称

返回

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

函数调用图:

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

removeTable()

void XuMQ::ExchangeMapper::removeTable ( )

inline

移除一张表

函数调用图:

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

selectCallback()

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

inlinestaticprivate

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

参数

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

返回

处理结果 0表示正常退出

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

类成员变量说明

_sql_helper

SqliteHelper XuMQ::ExchangeMapper::_sql_helper

private

数据库操作对象