XuMQ::BindingMapper类 参考

绑定信息持久化管理类 更多...

#include <binding.hpp>

XuMQ::BindingMapper 的协作图:

Public 成员函数
	BindingMapper (const std::string &dbfile)
	绑定信息持久化管理类 构造函数
void	createTable ()
	创建一张表
void	removeTable ()
	移除一张表
bool	insert (Binding::ptr &binding)
	新增一个绑定信息
bool	remove (const std::string &ename, const std::string &qname)
	移除一个绑定信息
bool	removeExchangeBindings (const std::string &ename)
	移除交换机绑定信息
bool	removeQueueBindings (const std::string &qname)
	移除消息队列绑定信息
BindingMap	recovery ()
	获取所有绑定信息 从数据库加载到内存

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

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

详细描述

绑定信息持久化管理类

构造及析构函数说明

BindingMapper()

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

inline

绑定信息持久化管理类 构造函数

参数

dbfile

数据库名称

注解

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

函数调用图:

成员函数说明

createTable()

void XuMQ::BindingMapper::createTable ( )

inline

创建一张表

函数调用图:

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

insert()

bool XuMQ::BindingMapper::insert ( Binding::ptr &  binding )

inline

新增一个绑定信息

参数

binding

消息绑定信息指针

返回

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

函数调用图:

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

recovery()

BindingMap XuMQ::BindingMapper::recovery ( )

inline

获取所有绑定信息 从数据库加载到内存

返回

一张映射表 交换机->消息队列绑定映射表的映射表

参见

BindingMap

函数调用图:

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

remove()

bool XuMQ::BindingMapper::remove ( const std::string &  ename, const std::string &  qname  )

inline

移除一个绑定信息

参数

ename	交换机名称
qname	消息队列名称

返回

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

函数调用图:

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

removeExchangeBindings()

bool XuMQ::BindingMapper::removeExchangeBindings ( const std::string &  ename )

inline

移除交换机绑定信息

参数

ename

交换机名称

返回

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

函数调用图:

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

removeQueueBindings()

bool XuMQ::BindingMapper::removeQueueBindings ( const std::string &  qname )

inline

移除消息队列绑定信息

参数

ename

消息队列名称

返回

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

函数调用图:

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

removeTable()

void XuMQ::BindingMapper::removeTable ( )

inline

移除一张表

函数调用图:

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

selectCallback()

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

inlinestaticprivate

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

参数

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

返回

处理结果 0表示正常退出

注解

防止交换机相关绑定信息已经存在 不能直接创建队列映射 会覆盖历史数据 先获取交换机的映射对象 向其中添加数据 若交换机没有映射信息 使用引用则会自动创建

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

类成员变量说明

_sql_helper

SqliteHelper XuMQ::BindingMapper::_sql_helper

private

数据库操作对象