Linux(Unix)下MySQL数据库访问接口程序MCI (MySQL Cal

需要的朋友可加我QQ，我把源代码全部发给你!

mci.h

#ifndef _MCI_H_

#define _MCI_H_

#include

#include

#include

#include

#include

#include

#include "mysql.h"

const unsigned int MAX_FIELD_LEN = 1024*1;

class MCIException

{

public:

int ErrNo;

charErrInfo[256];

public:

MCIException(const char *errinfo,int errno);

char *getErrInfo();

int getErrNo(){return ErrNo;};

//自定义错误类型

//1 不支持的字段类型

//2 字段越界

//3 字段不存在

//MySQL内部错误类型

//2002 Can't connect to local MySQL server through socket

//2003 Can't connect to MySQL server

//2006 MySQL server has gone away

//2013 Lost connection to MySQL server during query

//1045 Access denied for user

};

class MCIDatabase

{

public:

int Valid;

char DBIP[20]; //数据库IP地址

char User[10]; //用户名

char Pwd[10]; //密码

char DBName[20]; //数据库名

MYSQL *mysql;

public:

MCIDatabase();

~MCIDatabase(){};

MYSQL* getMySQL(){return mysql;};

void setLogin(const char* dbip,const char* usr, const char* pwd, const char* dbname) ;

int connect();

void disConnect();

};

class MCIField

{

public:

friend class MCIQuery;

MCIQuery* pParentQuery;//指向该Field所属于的Query

char FieldName[30]; //字段名称(目前支持30长度)

char StrBuf[255];//用于保存转换为字符串后的值

unsigned char* DataBuf;//预绑定缓冲区

enum_field_types FieldType;//MySQL内部数据类型

unsigned int FieldLength;//数据长度

public:

MCIField();

~MCIField();

void setFieldName(const char* s);

void setFieldType(enum_field_types n);

void setFieldLength(unsigned int n);

char* getFieldName();

char* getStrBuf();

enum_field_types getFieldType();

unsigned int getFieldLength();

MCIQuery* getParentQuery();

void setParentQuery(MCIQuery* pQry);

static void trimLeft(char* str);

static void trimRight(char* str);

static char* allTrim(char* str);

char* asString();

int asInteger();

float asFloat();

char asChar(int pos = 0);

};

class MCIQuery

{

public:

MCIDatabase* pDB;

MYSQL_RES* pRes;

int FieldNum; //字段个数

MYSQL_FIELD* pFields; //得到的字段信息

MCIField* pMCIFieldList; //在内部保存的所有字段信息

MYSQL_ROW Row;

int RowNum;

char SqlStr[1024*3];

int CurrRow;

public:

MCIQuery();

void setDB(MCIDatabase *dblink);

~MCIQuery();

void setSql(char* sqlstr);

void open(); //执行select型SQL语句

int getFieldsDef(); //获得字段信息,并为字段分配取值的缓冲区

int getRecordCount();//返回查询到的符合条件的记录的条数

int next(); //移动到下一个记录,同时获取字段值

MCIField* field(int i); //取相应字段值

MCIField* fieldByName(const char* s);

void exec(); //执行insert,update型SQL语句,返回被此语句影响的记录条数

void close();//关闭一个Query,为下次执行做准备

};

#endif

makefile

CC = g++

CFLAGS = -Wall

SQLHOME = -L/usr/lib64 -lmysqlclient

all:test

test: mci.o test.o

$(CC) -s -o test -m64 *.o $(SQLHOME)

mci.o: mci.cpp mci.h

$(CC) $(CFLAGS) -c mci.cpp

test.o: test.cpp test.h

$(CC) $(CFLAGS) -c test.cpp

clean::

rm -f *.o

（编辑：晋中站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!