Chinaunix首页 | 论坛 | 博客
  • 博客访问: 358212
  • 博文数量: 46
  • 博客积分: 4936
  • 博客等级: 上校
  • 技术积分: 575
  • 用 户 组: 普通用户
  • 注册时间: 2008-12-25 20:14
文章分类

全部博文(46)

文章存档

2012年(4)

2011年(1)

2010年(23)

2009年(18)

分类: Mysql/postgreSQL

2009-09-18 21:46:58

文件: cppmysql.rar
大小: 6KB
下载: 下载
网上对mysql的c++封装类都不太好,这是我封装的mysql封装类,大家可以任意使用,如果有问题请与我联系。
 
//.h
////////////////////////////////////////////////////////////////////////////////
// CppMysql - A C++ wrapper around the mysql database library.
//
// Copyright (c) 2009 Rob Groves. All Rights Reserved.
//
// Permission to use, copy, modify, and distribute this software and its
// documentation for any purpose, without fee, and without a written
// agreement, is hereby granted, provided that the above copyright notice,
// this paragraph and the following two paragraphs appear in all copies,
// modifications, and distributions.
//
// IN NO EVENT SHALL THE AUTHOR BE LIABLE TO ANY PARTY FOR DIRECT,
// INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES, INCLUDING LOST
// PROFITS, ARISING OUT OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION,
// EVEN IF THE AUTHOR HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
//
// THE AUTHOR SPECIFICALLY DISCLAIMS ANY WARRANTIES, INCLUDING, BUT NOT
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
// PARTICULAR PURPOSE. THE SOFTWARE AND ACCOMPANYING DOCUMENTATION, IF
// ANY, PROVIDED HEREUNDER IS PROVIDED "AS IS". THE AUTHOR HAS NO OBLIGATION
// TO PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, OR MODIFICATIONS.
//
// u can use it for anything, but u must show the source
// frome http://rainfish.cublog.cn
// by ben
// if u find some questions, please tell me with email
//
// V1.0  18/09/2009 -Initial Version for cppmysql
////////////////////////////////////////////////////////////////////////////////
#ifndef _CPP_MYSQL_1_H_
#define _CPP_MYSQL_1_H_
#include "mysql.h"

typedef unsigned int u_int;
typedef unsigned long u_long;
typedef MYSQL*  DB_HANDLE;
class CppMySQL3DB;
class CppMySQLQuery
{
 friend class CppMySQL3DB;
public:
    CppMySQLQuery();
 //当执行拷贝构造函数后,括号里的类已经无效,不能再使用
    CppMySQLQuery(CppMySQLQuery& rQuery);
 //当执行赋值构造函数后,=右边的类已经无效,不能再使用
    CppMySQLQuery& operator=(CppMySQLQuery& rQuery);
    virtual ~CppMySQLQuery();
 u_long numRow();//多少行
    int numFields();//多少列
    int fieldIndex(const char* szField);
 //0...n-1列
    const char* fieldName(int nCol);
 //   const char* fieldDeclType(int nCol);
 //   int fieldDataType(int nCol);
 u_long seekRow(u_long offerset);
    int getIntField(int nField, int nNullValue=0);
    int getIntField(const char* szField, int nNullValue=0);
    double getFloatField(int nField, double fNullValue=0.0);
    double getFloatField(const char* szField, double fNullValue=0.0);
 //0...n-1列
    const char* getStringField(int nField, const char* szNullValue="");
    const char* getStringField(const char* szField, const char* szNullValue="");
    const unsigned char* getBlobField(int nField, int& nLen);
    const unsigned char* getBlobField(const char* szField, int& nLen);
    bool fieldIsNull(int nField);
    bool fieldIsNull(const char* szField);
    bool eof();
    void nextRow();
    void finalize();
private:
 void freeRes();
    void checkVM();
private:
 MYSQL_RES*  _mysql_res;
 MYSQL_FIELD* _field;
 MYSQL_ROW  _row;
 u_long   _row_count;
 u_int   _field_count;

};
class CppMySQL3DB
{
public:
    CppMySQL3DB();
    virtual ~CppMySQL3DB();
    int open(const char* host, const char* user, const char* passwd, const char* db,
  unsigned int port = 0, unsigned long client_flag = 0);
    void close();
 /* 返回句柄 */
 MYSQL* getMysql();
 /* 处理返回多行的查询,返回影响的行数 */
 //返回引用是因为在CppMySQLQuery的赋值构造函数中要把成员变量_mysql_res置为空
 CppMySQLQuery& querySQL(const char *sql);
 /* 执行非返回结果查询 */
 int execSQL(const char* sql);
 /* 测试mysql服务器是否存活 */
 int ping();
 /* 关闭mysql 服务器 */
 int shutDown();
 /* 主要功能:重新启动mysql 服务器 */
 int reboot();
 /*
 * 说明:事务支持InnoDB or BDB表类型
    */
 /* 主要功能:开始事务 */
 int startTransaction();
 /* 主要功能:提交事务 */
 int commit();
 /* 主要功能:回滚事务 */
 int rollback();
 /* 得到客户信息 */
 const char * getClientInfo();
 /* 主要功能:得到客户版本信息 */
 const unsigned long  getClientVersion();
 /* 主要功能:得到主机信息 */
 const char * getHostInfo();
 /* 主要功能:得到服务器信息 */
 const char * getServerInfo();
 /*主要功能:得到服务器版本信息*/
 const unsigned long  getServerVersion();
 /*主要功能:得到 当前连接的默认字符集*/
 const char *  getCharacterSetName();
 /* 得到系统时间 */
 const char * getSysTime();
 /* 建立新数据库 */
 int createDB(const char* name);
 /* 删除制定的数据库*/
 int dropDB(const char* name);
 bool tableExists(const char* table);
    u_int lastRowId();
    void setBusyTimeout(int nMillisecs){};
private:
    CppMySQL3DB(const CppMySQL3DB& db);
    CppMySQL3DB& operator=(const CppMySQL3DB& db);
    void checkDB();
private:
 /* msyql 连接句柄 */
 MYSQL* _db_ptr;
 CppMySQLQuery _db_query;
};
#endif
 
 
//.cpp
///////////////////////////////////////////////////////////////////////////////
阅读(9675) | 评论(2) | 转发(1) |
给主人留下些什么吧!~~

254094982013-10-21 17:00:10

没有异常处理啊,把异常处理加上就更好用了

chinaunix网友2010-11-05 17:49:36

多谢了