mirror of
https://github.com/MariaDB/server.git
synced 2025-01-30 10:31:54 +01:00
c086a96b94
when joining a table to a MYSQL indexed table. modified: storage/connect/myconn.cpp modified: storage/connect/myconn.h modified: storage/connect/tabmysql.cpp - Fix an error causing JDBC table to fail saying when joining a table to a JDBC indexed table. added: storage/connect/tabjdbc.cpp - Add more tests to the mysql_index.test file modified: storage/connect/mysql-test/connect/r/mysql_index.result modified: storage/connect/mysql-test/connect/t/mysql_index.test - Add dummy JDBC support (NIY) modified: storage/connect/CMakeLists.txt - Typo modified: storage/federatedx/ha_federatedx.cc
103 lines
3.9 KiB
C++
103 lines
3.9 KiB
C++
/***********************************************************************/
|
|
/* MYCONN.H Olivier Bertrand 2007-2013 */
|
|
/* */
|
|
/* This is the declaration file for the MySQL connection class and */
|
|
/* a few utility functions used to communicate with MySQL. */
|
|
/* */
|
|
/* DO NOT define DLL_EXPORT in your application so these items are */
|
|
/* declared are imported from the Myconn DLL. */
|
|
/***********************************************************************/
|
|
#if defined(__WIN__)
|
|
#include <winsock.h>
|
|
#else // !__WIN__
|
|
#include <sys/socket.h>
|
|
#endif // !__WIN__
|
|
#include <mysql.h>
|
|
#include <errmsg.h>
|
|
#include "myutil.h"
|
|
|
|
#if defined(__WIN__) && defined(MYCONN_EXPORTS)
|
|
#if defined(DLL_EXPORT)
|
|
#define DllItem _declspec(dllexport)
|
|
#else // !DLL_EXPORT
|
|
#define DllItem _declspec(dllimport)
|
|
#endif // !DLL_EXPORT
|
|
#else // !__WIN__ || !MYCONN_EXPORTS
|
|
#define DllItem
|
|
#endif // !__WIN__
|
|
|
|
#define MYSQL_ENABLED 0x00000001
|
|
#define MYSQL_LOGON 0x00000002
|
|
|
|
typedef class MYSQLC *PMYC;
|
|
|
|
/***********************************************************************/
|
|
/* Prototypes of info functions. */
|
|
/***********************************************************************/
|
|
PQRYRES MyColumns(PGLOBAL g, THD *thd, const char *host, const char *db,
|
|
const char *user, const char *pwd,
|
|
const char *table, const char *colpat,
|
|
int port, bool info);
|
|
|
|
PQRYRES SrcColumns(PGLOBAL g, const char *host, const char *db,
|
|
const char *user, const char *pwd,
|
|
const char *srcdef, int port);
|
|
|
|
uint GetDefaultPort(void);
|
|
|
|
/* -------------------------- MYCONN class --------------------------- */
|
|
|
|
/***********************************************************************/
|
|
/* MYSQLC exported/imported class. A MySQL connection. */
|
|
/***********************************************************************/
|
|
class DllItem MYSQLC {
|
|
friend class TDBMYSQL;
|
|
friend class MYSQLCOL;
|
|
friend class TDBMYEXC;
|
|
// Construction
|
|
public:
|
|
MYSQLC(void);
|
|
|
|
// Implementation
|
|
int GetRows(void) {return m_Rows;}
|
|
bool Connected(void);
|
|
|
|
// Methods
|
|
int GetResultSize(PGLOBAL g, PSZ sql);
|
|
int GetTableSize(PGLOBAL g, PSZ query);
|
|
int Open(PGLOBAL g, const char *host, const char *db,
|
|
const char *user= "root", const char *pwd= "*",
|
|
int pt= 0, const char *csname = NULL);
|
|
int KillQuery(ulong id);
|
|
int ExecSQL(PGLOBAL g, const char *query, int *w = NULL);
|
|
int ExecSQLcmd(PGLOBAL g, const char *query, int *w);
|
|
#if defined(MYSQL_PREPARED_STATEMENTS)
|
|
int PrepareSQL(PGLOBAL g, const char *query);
|
|
int ExecStmt(PGLOBAL g);
|
|
int BindParams(PGLOBAL g, MYSQL_BIND *bind);
|
|
#endif // MYSQL_PREPARED_STATEMENTS
|
|
PQRYRES GetResult(PGLOBAL g, bool pdb = FALSE);
|
|
int Fetch(PGLOBAL g, int pos);
|
|
char *GetCharField(int i);
|
|
int GetFieldLength(int i);
|
|
int Rewind(PGLOBAL g, PSZ sql);
|
|
void FreeResult(void);
|
|
void Close(void);
|
|
|
|
protected:
|
|
MYSQL_FIELD *GetNextField(void);
|
|
void DataSeek(my_ulonglong row);
|
|
|
|
// Members
|
|
MYSQL *m_DB; // The return from MySQL connection
|
|
MYSQL_STMT *m_Stmt; // Prepared statement handle
|
|
MYSQL_RES *m_Res; // Points to MySQL Result
|
|
MYSQL_ROW m_Row; // Point to current row
|
|
int m_Rows; // The number of rows of the result
|
|
int N;
|
|
int m_Fields; // The number of result fields
|
|
int m_Afrw; // The number of affected rows
|
|
bool m_Use; // Use or store result set
|
|
const char *csname; // Table charset name
|
|
}; // end of class MYSQLC
|
|
|