#ifndef QMYSQL_H
#define QMYSQL_H
#include"XQDatabaseObject.hpp"
class XQDatabaseData;
class XQLog;
#define XQMysqlInfo XQLog("XQMysql")
//mysql数据库
class XQMySql:public XQDatabaseObject
{
	Q_OBJECT
public:
	XQMySql(QObject* parent=nullptr);
	XQMySql(QString SqlName,QString host, quint16 port, QString name, QString password, QString DataBase, QObject* parent = nullptr);
	XQMySql(QString host,quint16 port,QString name ,QString password,QString DataBase, QObject* parent = nullptr);
	~XQMySql();
public:
	//拷贝数据库
	XQMySql* cloneDatabase( const QString& connectionName = QString());
	//获取连接失败重连次数
	int reconnectionCount()const;
	//获取延迟时间
	int sleepTime()const;
public:
	//连接MySql数据库
	void connection(QString SqlName, QString host, quint16 port, QString name, QString password, QString DataBase);
	//添加服务器的主机地址和端口
	void addHostPort(QString host, quint16 port);
	//删除一个主机
	void removeHostPort(QString host);
	//设置连接失败重连次数
	void setReconnectionCount(int count);
	//设置延迟时间
	void setSleepTime(int sleep);
protected:
	void init();
	//打开数据库 重连次数 延迟时间秒
	bool openDatabase(QSqlDatabase& database,int count=0,int sleep=5);
protected:
	//static XQLog* m_log;//mysql全局日志
	QMap<QString,quint16> m_hostPort;//主机和端口列表
	int m_reconnectionCount = 0;//重连次数
	int m_sleepTime = 5;//延迟时间
};
#endif