ultimatepp/uppsrc/MySql/MySql.h

#ifndef __mysql_h__
#define __mysql_h__

// debian: sudo apt-get install libmysqlclient-dev

#ifndef flagNOMYSQL

#include <Sql/Sql.h>
#include <mysql.h>

#ifndef MYSQL_PORT // missing in mariadb client
#define MYSQL_PORT 3306
#endif

namespace Upp {

const char *MySqlReadString(const char *s, String& stmt);

bool MySqlPerformScript(const String& text, StatementExecutor& se, Gate<int, int> progress_canceled = Null);
#ifdef NOAPPSQL
bool MySqlUpdateSchema(const SqlSchema& sch, int i, StatementExecutor& se);
#else
bool MySqlUpdateSchema(const SqlSchema& sch, int i, StatementExecutor& se = SQLStatementExecutor());
#endif

String MySqlTextType(int n);

class MySqlSession : public SqlSession {
public:
	virtual bool           IsOpen() const;
	virtual RunScript      GetRunScript() const             { return &MySqlPerformScript; }
	virtual Vector<String> EnumUsers();
	virtual Vector<String> EnumDatabases();
	virtual Vector<String> EnumTables(String database);

protected:
	virtual SqlConnection *CreateConnection();

private:
	MYSQL *mysql;
	String username;
	double lastid;
	int    level;

	String connect_user;
	String connect_password;
	String connect_database;
	String connect_host;
	int    connect_port;
	String connect_socket;

	bool MysqlQuery(const char *query);
	bool DoConnect();
	
	friend class MySqlConnection;
	typedef MySqlSession CLASSNAME;

public:
	Gate<>               WhenReconnect;

	bool Connect(const char *user = NULL, const char *password = NULL, const char *database = NULL,
		         const char *host = NULL, int port = MYSQL_PORT, const char *socket = NULL);
	bool Open(const char *connect);
	bool Reconnect();
	void Close();

	String   GetUser()   { return username; }

	operator MYSQL *()   { return mysql; }

	virtual void   Begin();
	virtual void   Commit();
	virtual void   Rollback();
	virtual int    GetTransactionLevel() const;
	
	void    AutoReconnect()   { WhenReconnect = THISBACK(Reconnect); }

	MySqlSession()       { mysql = NULL; Dialect(MY_SQL); }
	~MySqlSession()      { Close(); }
};

}

#endif

#endif