Cocos2d-x分享一个封装的Sqlite3的DBUtil类

Cocos2d-x 前端之家
前端之家收集整理的这篇文章主要介绍了Cocos2d-x分享一个封装的Sqlite3的DBUtil类，前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。

原地址：http://cn.cocos2d-x.org/tutorial/show?id=2172

在Cocos2d-x中使用sqlite作为游戏持久化的解决方案是个不错的选择，使用json或者xml等文件存储的IO读写性能在手机设备上比较差，通常使用Xml和Json等文件存储数据时，因为实时的通过IO读取文件操作非常耗时，往往在游戏启动的时候把数据读取出来放到游戏的缓存中，使用时去缓存中查询，这样会占用大量的内存，如果不想使用缓存的机制来查询，使用sqlite3数据库是个不错的解决方案，我做过测试，在拥有100条记录的表中查询出一条数据，只需要1ms，通常游戏的帧率设置为60，每一帧的时间为1/60秒=16ms，1ms的查询时间是可以接受的，在游戏中每一帧要做大量的操作，cpu的逻辑运算，GPU的运算以及图形的渲染，如果1帧消耗的总时间>16ms，也就是线程Thread的sleep()的时间超过了16ms，则可能造成降帧，或者卡帧。所以数据读取对于游戏的性能影响还是很大的，一定要避免在游戏循环中进行文件的IO的操作，数据库的IO操作也不行。


分享一个Cocos2d-x访问sqlite3数据库的单例的DBUitl类，对增删改查以及事务操作等常用的API进行了一下简单的封装，还有很多不太完善的地方，希望大家帮我改进。


分别对Cocos的2.x版本和3.x版本进行了封装。

使用方法很简单，直接在项目的dao层调用DBUtil::getInstance()->xxxMethod(params..)即可，这里就不列举使用的demo了，把DBUtil的实现源码贴一下。

2.x版
DBUtil.h

//
//  DBUtil.h
//  LeadinV1.1
//
//  Created by ChengChao on 14-11-4.
//
//
 
#ifndef __LeadinV1_1__DBUtil__
#define __LeadinV1_1__DBUtil__
 
#include "main.h"
#include "sqlite3.h"
 
USING_NS_CC;
using namespace std;
 
class DBUtil {
     
private:
     
    //数据库
    sqlite3* m_pDataBase;
     
private:
     
#pragma mark <构造 && 析构>
     
    DBUtil();
     
    DBUtil(const DBUtil&);
     
    DBUtil& operator = (const DBUtil&);
     
    virtual ~DBUtil();
     
public:
     
#pragma mark <创建 && 销毁单例>
     
    static DBUtil* getInstance();
     
    static void destoryInstance();
     
#pragma mark <数据库操作>
     
    /**
     *  打开数据库(创建)
     *
     *  @param aDataBaseName 数据库名
     */
    void openDBWithName(string aDataBaseName);
     
    /**
     *  关闭数据库
     */
    void closeDB();
     
    /**
     *  创建数据表
     *
     *  @param asql       建表sql语句
     *  @param aTableName 表名
     */
    void createTable(string asql,string aTableName);
     
    /**
     *  通过表名查询该表是否存在
     *
     *  @param aTabelName 表秒
     *
     *  @return true: 存在 false: 不存在
     */
    bool isExistTableByName(string aTabelName);
     
    /**
     *  删除数据表
     *
     *  @param asql       删表sql语句
     *  @param aTableName 表名
     */
    void deleteTable(string asql,string aTableName);
     
    /**
     *  插入记录
     *
     *  @param asql 插入数据sql语句
     */
    void insertData(string asql);
     
    /**
     *  删除记录
     *
     *  @param asql 删除数据sql语句
     */
    void deleteData(string asql);
     
    /**
     *  修改记录
     *
     *  @param asql 修改数据sql语句
     */
    void updateData(string asql);
     
    /**
     *  查询记录
     *
     *  @param asql     修改数据sql语句
     */
    vector<map<string,string> >searchData(string asql);
     
    /**
     *  查询记录的条数
     *
     *  @param sql 查询记录sql语句
     *
     *  @return 记录条数
     */
    int searchDataCount(string asql);
     
    /**
     *  开始事务
     *
     *  @return 操作结果(sqlite3提供的宏)
     */
    int beginTransaction();
     
    /**
     *  提交事务(失败回滚)
     *
     *  @param aResult       操作结果
     *
     *  @return 操作结果(sqlite3提供的宏)
     */
    int comitTransaction(int aResult);
     
};
 
#endif /* defined(__LeadinV1_1__DBUtil__) */
DBUtil.cpp

@H_502_39@// // DBUtil.cpp // LeadinV1.1 // // Created by ChengChao on 14-11-4. // // #include "DBUtil.h" #include "NTool.h" static DBUtil* s_pInstance = NULL; const string cDBName = "gamedb"; #pragma mark <构造 && 析构> DBUtil::DBUtil():m_pDataBase(NULL) { } DBUtil::~DBUtil() { } #pragma mark <创建 && 销毁单例> DBUtil* DBUtil::getInstance() { if (!s_pInstance) { s_pInstance = new DBUtil(); } return s_pInstance; } void DBUtil::destoryInstance() { delete s_pInstance; s_pInstance = NULL; } #pragma mark <数据库操作> /** * 打开数据库(创建) * * @param aDataBaseName 数据库名 */ void DBUtil::openDBWithName(string aDataBaseName) { string writeablePath = CCFileUtils::sharedFileUtils()->getWritablePath(); CCLOG("path=%s",writeablePath.c_str()); string dbPath = writeablePath + aDataBaseName; int result = sqlite3_open(dbPath.c_str(),&m_pDataBase); char* errMsg = NULL; if (result != sqlITE_OK) { CCLog("打开数据库失败，错误码:%d，错误原因:%s\n",result,errMsg); } if (errMsg) { sqlite3_free(errMsg); errMsg = NULL; } } /** * 关闭数据库 */ void DBUtil::closeDB() { if (m_pDataBase) { sqlite3_close(m_pDataBase); m_pDataBase = NULL; } } /** * 创建数据表 * * @param asql 建表sql语句 * @param aTableName 表名 * * @usage string sql = "create table user(id integer,username text,password text)"; */ void DBUtil::createTable(string asql,string aTableName) { openDBWithName(cDBName); if (!isExistTableByName(aTableName)) { char* errMsg = NULL; int result = sqlite3_exec(m_pDataBase,asql.c_str(),NULL,&errMsg); if (result != sqlITE_OK) { CCLog("创建表失败，错误码:%d，错误原因:%s\n",errMsg); } if (errMsg) { sqlite3_free(errMsg); errMsg = NULL; } } closeDB(); } /** * 是否存在某张数据表的查询回调 * * @return 0 */ int isExistTableCallback(void* para,int n_column,char ** column_value,char ** column_name) { bool *isExisted_= (bool*)para; *isExisted_= (**column_value) != '0'; return 0; } /** * 通过表名查询该表是否存在 * * @param aTabelName 表秒 * * @return true: 存在 false: 不存在 */ bool DBUtil::isExistTableByName(string aTabelName) { if (m_pDataBase) { //判断表是否存在 bool isExist; char* errMsg = NULL; string sql = "select count(type) from sqlite_master where type = 'table' and name = '" + aTabelName + "'"; int result = sqlite3_exec(m_pDataBase,sql.c_str(),isExistTableCallback,&isExist,&errMsg); if (result != sqlITE_OK) { CCLog("查询表是否存在失败，错误码:%d，错误原因:%s\n",errMsg); } if (errMsg) { sqlite3_free(errMsg); errMsg = NULL; } return isExist; } return false; } /** * 删除数据表 * * @param asql 删表sql语句 * @param aTableName 表名 * * @usage string sql = "drop table name"; */ void DBUtil::deleteTable(string asql,string aTableName) { openDBWithName(cDBName); beginTransaction(); int result = 0; if (isExistTableByName(aTableName)) { char* errMsg = NULL; result = sqlite3_exec(m_pDataBase,errMsg); } if (errMsg) { sqlite3_free(errMsg); errMsg = NULL; } } comitTransaction(result); closeDB(); } /** * 插入记录 * * @param asql 插入数据sql语句 * * @usage string sql = "insert into User(name) values ('cc') "; */ void DBUtil::insertData(string asql) { openDBWithName(cDBName); beginTransaction(); char* errMsg = NULL; int result = sqlite3_exec(m_pDataBase,&errMsg); if (result != sqlITE_OK) { CCLog("插入记录失败，错误码:%d，错误原因:%s\n",errMsg ); } if (errMsg) { sqlite3_free(errMsg); errMsg = NULL; } comitTransaction(result); closeDB(); } /** * 删除记录 * * @param asql 插入数据sql语句 * * @usage string sql = "delete from User where name = 'cc'"; */ void DBUtil::deleteData(string asql) { openDBWithName(cDBName); beginTransaction(); char* errMsg = NULL; int result = sqlite3_exec(m_pDataBase,&errMsg); if (result != sqlITE_OK ) { CCLog("删除记录失败，错误码:%d，错误原因:%s\n",errMsg); } if (errMsg) { sqlite3_free(errMsg); errMsg = NULL; } comitTransaction(result); closeDB(); } /** * 修改记录 * * @param asql 修改数据sql语句 */ void DBUtil::updateData(string asql) { openDBWithName(cDBName); beginTransaction(); char* errMsg = NULL; int result = sqlite3_exec(m_pDataBase,&errMsg ); if (result != sqlITE_OK) { CCLog( "修改记录失败，错误码:%d，错误原因:%s\n",errMsg ); } if (errMsg) { sqlite3_free(errMsg); errMsg = NULL; } comitTransaction(result); closeDB(); } /** * 查询回调 * * @return 0 */ int searchDataCallback(void* para,char** column_value,char** column_name ) { map<string,string> mapResults ; for (int i = 0; i < n_column; i++) { mapResults.insert(make_pair<string,string>((string)column_name[i],(string)column_value[i])); } vector<map<string,string> >* vect =(vector<map<string,string> >*)para; vect->push_back(mapResults); return 0; } /** * 查询记录 * * @param asql 修改数据sql语句 */ vector<map<string,string> > DBUtil::searchData(string asql) { long long int startTime = getNowTime(); CCLOG("startTime=%lld",getNowTime()); openDBWithName(cDBName); //vector是查询的结果集，每一个结果都存在map中 //map的第一string是key(字段名)，第二个string是value(查询出的对应数据) vector<map<string,string> > vec; char* errMsg = NULL; int result = sqlite3_exec(m_pDataBase,searchDataCallback,&vec,&errMsg); if (result != sqlITE_OK) { CCLog("查询失败，错误码:%d，错误原因:%s\n",errMsg); } if (errMsg) { sqlite3_free(errMsg); errMsg = NULL; } closeDB(); long long int endTime = getNowTime(); CCLOG("endTime=%lld",endTime); CCLOG("needTime=%lld",endTime - startTime); return vec; } /** * 查询数据条数回调 * * @return 0 */ int searchDataCountCallback(void* para,char** column_name) { int* count = (int*)para; *count = (int)atof(column_value[0]); return 0; } /** * 查询记录的条数 * * @param sql 查询记录sql语句 * * @return 记录条数 */ int DBUtil::searchDataCount(string asql) { openDBWithName(cDBName); int count = 0; char* errMsg = NULL; int result = sqlite3_exec(m_pDataBase,searchDataCountCallback,&count,&errMsg); if (result != sqlITE_OK) { CCLog( "查询记录条数失败，错误码:%d，错误原因:%s\n",errMsg); } if (errMsg) { sqlite3_free(errMsg); errMsg = NULL; } closeDB(); return count; } /** * 开始事务 * * @return 操作结果(sqlite3提供的宏) */ int DBUtil::beginTransaction() { char* errMsg = NULL; int result = sqlite3_exec(m_pDataBase,"begin transaction",&errMsg); if (result != sqlITE_OK ){ CCLog("开始事务记录失败，错误码:%d，错误原因:%s\n",errMsg); } return result; } /** * 提交事务(失败回滚) * * @param aResult 操作结果 * * @return 操作结果(sqlite3提供的宏) */ int DBUtil::comitTransaction(int aResult) { if (aResult == sqlITE_OK) { char* errMsg = NULL; int result = sqlite3_exec(m_pDataBase,"commit transaction",&errMsg); if (result != sqlITE_OK) { CCLog("提交事务记录失败，错误码:%d，错误原因:%s\n",errMsg); } return result; } else { char* errMsg = NULL; int result = sqlite3_exec(m_pDataBase,"rollback transaction",&errMsg); if (result != sqlITE_OK ) { CCLog("回滚事务记录失败，错误码:%d，错误原因:%s\n",errMsg); } return result; } }

3.x版

DBUtil.h 

//  DBUtil.h
//  GuessMovie
//
//  Created by apple on 14/11/24.
//
//
 
#ifndef __GuessMovie__DBUtil__
#define __GuessMovie__DBUtil__
 
#include "sqlite3.h"
#include "main.h"
 
USING_NS_CC;
 
class DBUtil {
     
private:
     
    //数据库
    sqlite3* m_pDataBase;
     
private:
     
#pragma mark <构造 && 析构>
     
    DBUtil();
     
    virtual ~DBUtil();
     
    public :
     
#pragma mark <创建 && 销毁单例>
     
    static DBUtil* getInstance();
     
    static void destoryInstance();
     
#pragma mark <数据库操作>
     
    /**
     *  打开数据库(创建)
     *
     *  @param aDataBaseName 数据库名
     */
    void openDBWithName(std::string aDataBaseName);
     
    /**
     *  关闭数据库
     */
    void closeDB();
     
    /**
     *  创建数据表
     *
     *  @param asql       建表sql语句
     *  @param aTableName 表名
     */
    void createTable(std::string asql,std::string aTableName);
     
    /**
     *  通过表名查询该表是否存在
     *
     *  @param aTabelName 表秒
     *
     *  @return true: 存在 false: 不存在
     */
    bool isExistTableByName(std::string aTabelName);
     
    /**
     *  删除数据表
     *
     *  @param asql       删表sql语句
     *  @param aTableName 表名
     */
    void deleteTable(std::string asql,std::string aTableName);
     
    /**
     *  插入记录
     *
     *  @param asql 插入数据sql语句
     */
    void insertData(std::string asql);
     
    /**
     *  删除记录
     *
     *  @param asql 删除数据sql语句
     */
    void deleteData(std::string asql);
     
    /**
     *  修改记录
     *
     *  @param asql 修改数据sql语句
     */
    void updateData(std::string asql);
     
    /**
     *  查询记录
     *
     *  @param asql     修改数据sql语句
     */
    std::vector<std::map<std::string,std::string> >searchData(std::string asql);
     
    /**
     *  查询记录的条数
     *
     *  @param sql 查询记录sql语句
     *
     *  @return 记录条数
     */
    int searchDataCount(std::string asql);
     
    /**
     *  开始事务
     *
     *  @return 操作结果(sqlite3提供的宏)
     */
    int beginTransaction();
     
    /**
     *  提交事务(失败回滚)
     *
     *  @param aResult       操作结果
     *
     *  @return 操作结果(sqlite3提供的宏)
     */
    int comitTransaction(int aResult);
     
};
 
#endif /* defined(__GuessMovie__DBUtil__) */
DBUtil.cpp 

//  DBUtil.cpp
//  GuessMovie
//
//  Created by apple on 14/11/24.
//
//
 
#include "DBUtil.h"
 
static DBUtil* s_pInstance = NULL;
 
const std::string cDBName = "gamedb";
 
#pragma mark <构造 && 析构>
 
DBUtil::DBUtil():m_pDataBase(NULL) {
     
}
 
DBUtil::~DBUtil() {
     
}
 
#pragma mark <创建 && 销毁单例>
 
DBUtil* DBUtil::getInstance() {
    if (!s_pInstance) {
        s_pInstance = new DBUtil();
    }
    return s_pInstance;
}
 
void DBUtil::destoryInstance() {
    delete s_pInstance;
    s_pInstance = NULL;
}
 
#pragma mark <数据库操作>
 
/**
 *  打开数据库(创建)
 *
 *  @param aDataBaseName 数据库名
 */
void DBUtil::openDBWithName(std::string aDataBaseName) {
    std::string writeablePath = FileUtils::getInstance()->getWritablePath();
    CCLOG("path=%s",writeablePath.c_str());
    std::string dbPath = writeablePath + aDataBaseName;
     
    int result = sqlite3_open(dbPath.c_str(),&m_pDataBase);
    char* errMsg = NULL;
    if (result != sqlITE_OK) {
        log("打开数据库失败，错误码:%d，错误原因:%s\n",password text)";
 */
void DBUtil::createTable(std::string asql,std::string aTableName) {
     
    openDBWithName(cDBName);
     
    if (!isExistTableByName(aTableName)) {
        char* errMsg = NULL;
        int result = sqlite3_exec(m_pDataBase,&errMsg);
        if (result != sqlITE_OK) {
            log("创建表失败，错误码:%d，错误原因:%s\n",char ** column_name) {
    bool *isExisted_= (bool*)para;
    *isExisted_= (**column_value) != '0';
    return 0;
}
 
/**
 *  通过表名查询该表是否存在
 *
 *  @param aTabelName 表秒
 *
 *  @return true: 存在 false: 不存在
 */
bool DBUtil::isExistTableByName(std::string aTabelName) {
     
    if (m_pDataBase) {
        //判断表是否存在
        bool isExist;
        char* errMsg = NULL;
        std::string sql = "select count(type) from sqlite_master where type = 'table' and name = '" + aTabelName + "'";
        int result = sqlite3_exec(m_pDataBase,&errMsg);
         
        if (result != sqlITE_OK) {
            log("查询表是否存在失败，错误码:%d，错误原因:%s\n",errMsg);
        }
         
        if (errMsg) {
            sqlite3_free(errMsg);
            errMsg = NULL;
        }
         
        return isExist;
    }
     
    return false;
}
 
/**
 *  删除数据表
 *
 *  @param asql       删表sql语句
 *  @param aTableName 表名
 *
 *  @usage string sql = "drop table name";
 */
void DBUtil::deleteTable(std::string asql,std::string aTableName) {
     
    openDBWithName(cDBName);
     
    beginTransaction();
     
    int result = 0;
    if (isExistTableByName(aTableName)) {
        char* errMsg = NULL;
        result = sqlite3_exec(m_pDataBase,errMsg);
        }
         
        if (errMsg) {
            sqlite3_free(errMsg);
            errMsg = NULL;
        }
    }
     
    comitTransaction(result);
     
    closeDB();
     
}
 
/**
 *  插入记录
 *
 *  @param asql 插入数据sql语句
 *
 *  @usage string sql = "insert into User(name) values ('cc') ";
 */
void DBUtil::insertData(std::string asql) {
     
    openDBWithName(cDBName);
     
    beginTransaction();
     
    char* errMsg = NULL;
    int result = sqlite3_exec(m_pDataBase,&errMsg);
    if (result != sqlITE_OK) {
        log("插入记录失败，错误码:%d，错误原因:%s\n",errMsg );
    }
     
    if (errMsg) {
        sqlite3_free(errMsg);
        errMsg = NULL;
    }
     
    comitTransaction(result);
     
    closeDB();
}
 
/**
 *  删除记录
 *
 *  @param asql 插入数据sql语句
 *
 *  @usage string sql = "delete from User where name = 'cc'";
 */
void DBUtil::deleteData(std::string asql) {
     
    openDBWithName(cDBName);
     
    beginTransaction();
     
    char* errMsg = NULL;
    int result = sqlite3_exec(m_pDataBase,&errMsg);
    if (result != sqlITE_OK ) {
        log("删除记录失败，错误码:%d，错误原因:%s\n",errMsg);
    }
     
    if (errMsg) {
        sqlite3_free(errMsg);
        errMsg = NULL;
    }
     
    comitTransaction(result);
     
    closeDB();
     
}
 
/**
 *  修改记录
 *
 *  @param asql 修改数据sql语句
 */
void DBUtil::updateData(std::string asql) {
     
    openDBWithName(cDBName);
     
    beginTransaction();
     
    char* errMsg = NULL;
    int result = sqlite3_exec(m_pDataBase,&errMsg );
    if (result != sqlITE_OK) {
        log( "修改记录失败，错误码:%d，错误原因:%s\n",char** column_name ) {
    std::map<std::string,std::string> mapResults ;
    for (int i = 0; i < n_column; i++) {
        mapResults.insert(std::make_pair<std::string,std::string>((std::string)column_name[i],(std::string)column_value[i]));
    }
    std::vector<std::map<std::string,std::string> >* vect = (std::vector<std::map<std::string,std::string> >*)para;
    vect->push_back(mapResults);
    return 0;
}
 
 
/**
 *  查询记录
 *
 *  @param asql     查询数据sql语句
 */
std::vector<std::map<std::string,std::string> > DBUtil::searchData(std::string asql) {
     
//    long long int startTime = getNowTime();
//    CCLOG("startTime=%lld",getNowTime());
     
    openDBWithName(cDBName);
     
    //vector是查询的结果集，每一个结果都存在map中
    //map的第一string是key(字段名)，第二个string是value(查询出的对应数据)
    std::vector<std::map<std::string,std::string> > vec;
     
    char* errMsg = NULL;
    int result = sqlite3_exec(m_pDataBase,&errMsg);
    if (result != sqlITE_OK) {
        log("查询失败，错误码:%d，错误原因:%s\n",errMsg);
    }
     
    if (errMsg) {
        sqlite3_free(errMsg);
        errMsg = NULL;
    }
     
    closeDB();
     
//    long long int endTime = getNowTime();
//    CCLOG("endTime=%lld",endTime);
//    CCLOG("needTime=%lld",char** column_name) {
    int* count = (int*)para;
    *count = (int)atof(column_value[0]);
    return 0;
}
 
/**
 *  查询记录的条数
 *
 *  @param sql 查询记录sql语句
 *
 *  @return 记录条数
 */
int DBUtil::searchDataCount(std::string asql) {
     
    openDBWithName(cDBName);
     
    int count = 0;
    char* errMsg = NULL;
    int result = sqlite3_exec(m_pDataBase,&errMsg);
    if (result != sqlITE_OK) {
        log( "查询记录条数失败，错误码:%d，错误原因:%s\n",&errMsg);
    if (result != sqlITE_OK ){
        log("开始事务记录失败，错误码:%d，错误原因:%s\n",&errMsg);
        if (result != sqlITE_OK) {
            log("提交事务记录失败，错误码:%d，错误原因:%s\n",&errMsg);
        if (result != sqlITE_OK ) {
            log("回滚事务记录失败，错误码:%d，错误原因:%s\n",errMsg);
        }
        return result;
    }
}
原文链接：https://www.f2er.com/cocos2dx/345167.html

猜你在找的Cocos2d-x相关文章

创建自定义的Cocos2d-x场景
操作步骤 1、创建cocos2d-x工程 2、新建 Scene1.cpp Scene1.h Scene1.h代码 #ifndef __SCE...
给vs2010安装上cocos2d-x的模版
开发环境：OS(WINDOWS 8.1 X64 企业版) cocos2d-x 2.2.1 vs2010 想给vs安装上cocos的模版，...
Python创建Cocos2d-x 2.2方法
把创建项目做成一个批处理，当创建项目时可以省时省力很多。 操作步骤 1、在 E:cocos2d-x-...
cocos2dx 物理碰撞
https://www.cnblogs.com/JiaoQing/p/3906780.html 四个响应函数 1 EventListenerPhysics...
cocos2d-js 自定义事件监听派发
转载于 http://www.cnblogs.com/kenkofox/p/3926797.html 熟悉js的dom事件或者flash事件的...
cocos常用 实用 公共函数 lua代码
公共资源加载，缓存retain；防止被自动销毁 2. 数字滚动递增；用于得奖后，总金币跳动增加...
cocos creator box2d
title Map 使用box2d var sfloors = this.tiledMap.getObjectGroup(‘Special_Floor‘).g...
（转）让quick-cocos2d-x支持加密的plist文件
前篇：quick-cocos2d-x图片资源加密 在前篇里面，我们实现了图片资源的加密，但还没有实现...
（转）quick-cocos2d-x图片资源加密(续)
摘要: 对在quick-cocos2d-x上实现的资源加密方法的补充 前篇： quick-cocos2d-x图片资源加...
Cocos Creator 动态改变sprite图片
首先将存放图片最外层文件夹命名为resources 　　 changeBj: function(){ 　　　　var url...
iOSAndroidSwiftHybridCocos2d-xFlutterXcodeSilverlightcocoaCordova
调试桥筛选栏假异步不会丢失AndPermissio权限申请抽屉式systemUI信号栏多行排列跨多行显示viewmode数据共享录制语音视频通话多行显示Studio3.5拉伸控件望远镜发动态走势图点赞控件显示牌冷启动v3签名v2签名v1签名本地html外接键盘流式标签