net.neoremind.fountain.datasource
接口 MysqlDataSource

所有已知实现类：

AbstractHADatasource, AbstractMysqlDataSource, HANormalMysqlDataSource

public interface MysqlDataSource

抽象描述mysql的数据源,包括本地binlog, rowbase binlog,databus等

作者：

zhangxu

方法摘要

void	close() 关闭数据源
String	getIpAddress() 获取当前数据源的ip地址
int	getPort() 获取当前数据源的端口
boolean	isOpen() 数据源是否已经处于打开状态
void	open() 打开一个数据源,用以读取数据
ResultSetPacket	query(String query) 执行查询sql
TableMeta	queryTableMeta(String tableFullName) 查询给定表的schema
OKPacket	update(String query) 执行修改数据的sql

方法详细信息

open

void open()
          throws IOException,
                 NoSuchAlgorithmException,
                 TimeoutException

打开一个数据源,用以读取数据

抛出：

IOException

NoSuchAlgorithmException

TimeoutException

isOpen

boolean isOpen()

数据源是否已经处于打开状态

返回：

close

void close()

关闭数据源

update

OKPacket update(String query)
                throws IOException,
                       NoSuchAlgorithmException

执行修改数据的sql

参数：

query -

返回：

抛出：

IOException

NoSuchAlgorithmException

query

ResultSetPacket query(String query)
                      throws IOException,
                             NoSuchAlgorithmException

执行查询sql

参数：

query -

返回：

抛出：

IOException

NoSuchAlgorithmException

getIpAddress

String getIpAddress()

获取当前数据源的ip地址

返回：

getPort

int getPort()

获取当前数据源的端口

返回：

queryTableMeta

TableMeta queryTableMeta(String tableFullName)
                         throws IOException,
                                NoSuchAlgorithmException

查询给定表的schema

参数：

tableFullName -

返回：

抛出：

IOException

NoSuchAlgorithmException