mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-18 05:32:52 +00:00
113 lines
3.4 KiB
C++
113 lines
3.4 KiB
C++
#ifndef MYSQLXX_CONNECTION_H
|
||
#define MYSQLXX_CONNECTION_H
|
||
|
||
#include <boost/noncopyable.hpp>
|
||
|
||
#include <Poco/Util/Application.h>
|
||
|
||
#include <Yandex/singleton.h>
|
||
|
||
#include <mysqlxx/Query.h>
|
||
|
||
#define MYSQLXX_TIMEOUT 60
|
||
|
||
|
||
namespace mysqlxx
|
||
{
|
||
|
||
|
||
/** Для корректной инициализации и деинициализации MySQL библиотеки.
|
||
* Обеспечивает единственный и thread-safe вызов mysql_library_init().
|
||
* Использование:
|
||
* LibrarySingleton::instance();
|
||
*/
|
||
class LibrarySingleton : public Singleton<LibrarySingleton>
|
||
{
|
||
friend class Singleton<LibrarySingleton>;
|
||
private:
|
||
LibrarySingleton()
|
||
{
|
||
if (mysql_library_init(0, NULL, NULL))
|
||
throw Exception("Cannot initialize MySQL library.");
|
||
}
|
||
|
||
~LibrarySingleton()
|
||
{
|
||
mysql_library_end();
|
||
}
|
||
};
|
||
|
||
|
||
/** Соединение с MySQL.
|
||
* Использование:
|
||
* mysqlxx::Connection connection("Test", "127.0.0.1", "root", "qwerty", 3306);
|
||
* std::cout << connection.query("SELECT 'Hello, World!'").store().at(0).at(0).getString() << std::endl;
|
||
*
|
||
* Или так, если вы используете конфигурацию из библиотеки Poco:
|
||
* mysqlxx::Connection connection("mysql_params");
|
||
*/
|
||
class Connection : private boost::noncopyable
|
||
{
|
||
public:
|
||
/// Для отложенной инициализации.
|
||
Connection();
|
||
|
||
/// Создать соединение.
|
||
Connection(
|
||
const char* db,
|
||
const char* server,
|
||
const char* user = 0,
|
||
const char* password = 0,
|
||
unsigned int port = 0);
|
||
|
||
/** Конструктор-помошник. Создать соединение, считав все параметры из секции config_name конфигурации.
|
||
* Можно использовать, если вы используете Poco::Util::Application из библиотеки Poco.
|
||
*/
|
||
Connection(const std::string & config_name)
|
||
{
|
||
is_connected = false;
|
||
Poco::Util::LayeredConfiguration & cfg = Poco::Util::Application::instance().config();
|
||
|
||
std::string db = cfg.getString(config_name + ".db");
|
||
std::string server = cfg.getString(config_name + ".host");
|
||
std::string user = cfg.getString(config_name + ".user");
|
||
std::string password = cfg.getString(config_name + ".password");
|
||
unsigned port = cfg.getInt(config_name + ".port");
|
||
|
||
connect(db.c_str(), server.c_str(), user.c_str(), password.c_str(), port);
|
||
}
|
||
|
||
virtual ~Connection();
|
||
|
||
/// Для отложенной инициализации или для того, чтобы подключиться с другими параметрами.
|
||
virtual void connect(const char * db,
|
||
const char * server,
|
||
const char * user,
|
||
const char * password,
|
||
unsigned int port);
|
||
|
||
/// Было ли произведено соединение с MySQL.
|
||
bool connected() const;
|
||
|
||
/// Отсоединиться от MySQL.
|
||
void disconnect();
|
||
|
||
/// Если соединение утеряно - попытаться восстановить его. true - если после вызова соединение есть.
|
||
bool ping();
|
||
|
||
/// Создать запрос. Вы можете сразу указать его, передав строку, или заполнить потом.
|
||
Query query(const std::string & str = "");
|
||
|
||
/// Получить объект MYSQL из C API.
|
||
MYSQL * getDriver();
|
||
|
||
private:
|
||
MYSQL driver;
|
||
bool is_connected;
|
||
};
|
||
|
||
|
||
}
|
||
|
||
#endif
|