讲师中心 微信公众号
首页
文章
后端开发 web前端 数据库 开发工具 php框架 常见问题 人工智能 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 自媒体 新闻
专题
后端开发 web前端 数据库 开发工具 php框架 人工智能 Java 系统教程 电脑教程 硬件教程 手机教程 软件教程 游戏教程 新闻
AI工具
AI聊天问答 Agent智能体 AI文本写作 AI绘画作图 AI设计工具 AI视频创作 AI音频制作 AI办公学习 AI编程开发 AI提示词
学习
大前端 后端开发 数据库 移动端 运维开发 计算机基础
编程手册
大前端 后端开发 数据库 移动端 运维开发 计算机基础
下载
js特效 网站源码 工具下载 类库下载 网站素材 学习资源 插件扩展 手机游戏
最近更新
当前位置：首页 > 数据库 > mysql教程 >

正文

0

0

linuxCsqlite3mysql_MySQL

php中文网

php中文网

发布时间：2016-05-30 17:11:15

|

1356人浏览过

|

来源于php中文网

原创

/* ********** gcc main.c -lsqlite3 -I/usr/include/mysql -L/usr/lib/mysql -lmysqlclient ************

SQLITE_OK = 0; 返回成功
SQLITE_ERROR = 1; SQL错误或错误的数据库
SQLITE_INTERNAL = 2; An internal logic error in SQLite
SQLITE_PERM = 3; 拒绝访问
SQLITE_ABORT = 4; 回调函数请求中断
SQLITE_BUSY = 5; 数据库文件被锁
SQLITE_LOCKED = 6; 数据库中的一个表被锁
SQLITE_NOMEM = 7; 内存分配失败
SQLITE_READONLY = 8; 试图对一个只读数据库进行写操作
SQLITE_INTERRUPT = 9; 由sqlite_interrupt()结束操作
SQLITE_IOERR = 10; 磁盘I/O发生错误
SQLITE_CORRUPT = 11; 数据库磁盘镜像畸形
SQLITE_NOTFOUND = 12; (Internal Only)表或记录不存在
SQLITE_FULL = 13; 数据库满插入失败
SQLITE_CANTOPEN = 14; 不能打开数据库文件
SQLITE_PROTOCOL = 15; 数据库锁定协议错误
SQLITE_EMPTY = 16; (Internal Only)数据库表为空
SQLITE_SCHEMA = 17; 数据库模式改变
SQLITE_TOOBIG = 18; 对一个表数据行过多
SQLITE_CONSTRAINT = 19; 由于约束冲突而中止
SQLITE_MISMATCH = 20; 数据类型不匹配
SQLITE_MISUSE = 21; 数据库错误使用
SQLITE_NOLFS = 22; 使用主机操作系统不支持的特性
SQLITE_AUTH = 23; 非法授权
SQLITE_FORMAT = 24; 辅助数据库格式错误
SQLITE_RANGE = 25; 2nd parameter to sqlite_bind out of range
SQLITE_NOTADB = 26; 打开的不是一个数据库文件
SQLITE_ROW = 100; sqlite_step() has another row ready
SQLITE_DONE = 101; sqlite_step() has finished executing

*************************************************************************************************** */

#include "DB.h"

gseMutex dbMutex=GSE_MUTEX_INIT;
static int IsUpdateAll = 0;
static int iDelCount = 0;
const int FREE_NUM = 1000;
static int needVacuum = 0;

int DBOpen(dbClass *sqlDB, const char *sqlName, char *localhost, char *user, char *password)
{
    if(sqlDB == NULL || sqlName == NULL || 0 == strlen(sqlName))
    {
        gseLog(L_ERROR,"NULL *p");
        return -1;
    }

    int ret = 0;
    if(sqlDB->type == SQL_SQLITE3)
    {
        gseMutexLock(&dbMutex);
        sqlDB->db = (sqlite3 *)sqlDB->db;

        localhost = NULL;
        user = NULL;
        password = NULL;

        char sqlPathName[64]={0};
        sprintf(sqlPathName, "%s", sqlName);
        ret = sqlite3_open(sqlPathName, (struct sqlite3 **)&(sqlDB->db));
        if(ret != SQLITE_OK)
        {
            gseLog(L_ERROR,"ret = %d, Cannot open db: %s",ret,sqlite3_errmsg(sqlDB->db));
        }
        gseMutexUnlock(&dbMutex);
//      gseLog(L_INFO,"Open database");

    }
    else if(sqlDB->type == SQL_MYSQL)
    {
#ifdef MYSQL_DEFINE
        sqlDB->db = (MYSQL *)sqlDB->db;
        if(localhost == NULL || user == NULL || password == NULL)
        {
            gseLog(L_ERROR,"localhost user password is NULL");
            return -1;
        }

        char creatDbStr[64]={0};
        char useDbStr[64]={0};
        sprintf(creatDbStr, "create database %s", sqlName);
        sprintf(useDbStr, "use %s", sqlName);

        sqlDB->db= mysql_init(NULL);
        if (sqlDB->db== NULL) 
        {
            gseLog(L_ERROR,"sqlOpen Error 1 %u: %s", mysql_errno(sqlDB->db), mysql_error(sqlDB->db));
            exit(1);
        }
        if (mysql_real_connect(sqlDB->db, localhost, user, password, NULL, 0, NULL, 0) == NULL)
        {
            gseLog(L_ERROR,"sqlOpen Error 2 %u: %s", mysql_errno(sqlDB->db), mysql_error(sqlDB->db));
            exit(1);
        }
        ret = mysql_query(sqlDB->db, creatDbStr);
        if (ret) 
        {
            gseLog(L_ERROR,"sqlOpen Error 3 %u: %s", mysql_errno(sqlDB->db), mysql_error(sqlDB->db));
        }
        ret = mysql_query(sqlDB->db, useDbStr);
        if (ret) 
        {
            gseLog(L_ERROR,"sqlOpen Error 4 %u: %s", mysql_errno(sqlDB->db), mysql_error(sqlDB->db));
            exit(1);
        }
#endif

    }
    else
    {
        return -2;
    }
    return ret;

}

int DBClose(dbClass *sqlDB)
{
    if(NULL == sqlDB || NULL == sqlDB->db)
    {
        return -1;
    }
    int ret = 0;
    if(sqlDB->type == SQL_SQLITE3)
    {
        gseMutexLock(&dbMutex);
        sqlDB->db = (sqlite3 *)sqlDB->db;
        ret = sqlite3_close(sqlDB->db);
        gseMutexUnlock(&dbMutex);
    }
    else if(sqlDB->type == SQL_MYSQL)
    {
#ifdef MYSQL_DEFINE
        sqlDB->db = (MYSQL *)sqlDB->db;
        mysql_close(sqlDB->db);
#endif
    }
    else
    {
        return -2;
    }

//  gseLog(L_INFO, "Close database");
    return ret;
}

int DBCreate(dbClass *sqlDB, const char *tableName, char *creatValueStr)
{
    if(sqlDB == NULL || tableName == NULL || creatValueStr == NULL || NULL == sqlDB->db || 0 == strlen(creatValueStr))
    {
        gseLog(L_ERROR,"*db is NULL");
        return -1;
    }

    char *errmsg = 0;
    int ret = 0;
    char createString[MAX_SQLSTR]={0};
    if(strlen(creatValueStr) >= 1)
        creatValueStr[strlen(creatValueStr) - 1]='\0';
    sprintf(createString, "create table %s(%s)", tableName,creatValueStr);
    //create table tb_cardId(cardID KEY, cardNum INT, endDate INT, password NVARCHAR(8))
    memset(creatValueStr, 0, strlen(creatValueStr));

    if(sqlDB->type == SQL_SQLITE3)
    {
        gseMutexLock(&dbMutex);
        sqlDB->db = (sqlite3 *)sqlDB->db;
        ret = sqlite3_exec(sqlDB->db,createString,NULL,NULL,&errmsg);
        if(ret != SQLITE_OK)
        {
            gseLog(L_ERROR,"ret = %d, create table fail: %s", ret, errmsg);
        }
        else
            gseLog(L_INFO, "create table %s success.", tableName);
        sqlite3_free(errmsg);
        gseMutexUnlock(&dbMutex);
    }
    else if(sqlDB->type == SQL_MYSQL)
    {
#ifdef MYSQL_DEFINE
        sqlDB->db = (MYSQL *)sqlDB->db;

        ret = mysql_query(sqlDB->db, createString);
        if (ret)
        {
            gseLog(L_ERROR,"sqlCreate Error  %u: %s", mysql_errno(sqlDB->db), mysql_error(sqlDB->db));
        }
#endif
    }
    else
    {
        return -2;
    }


    return ret;
}

int DBInsert(dbClass *sqlDB, const char *tableName, char *valuesString)
{
    if(sqlDB == NULL || tableName == NULL || valuesString == NULL || NULL == sqlDB->db || 0 == strlen(valuesString))
    {
        gseLog(L_ERROR,"*db is NULL");
        return -1;
    }
    char *errmsg = 0;
    int ret = 0;
    char sqlInsetTable[MAX_SQLSTR]={0};
    if(strlen(valuesString) >= 1)
        valuesString[strlen(valuesString)-1]='\0';
    sprintf(sqlInsetTable, "insert into %s values(%s)",tableName,valuesString);
    //insert into tb_cardId values(1,124124343223,20130101,'12345678');
    memset(valuesString, 0, strlen(valuesString));

    if(sqlDB->type == SQL_SQLITE3)
    {
        gseMutexLock(&dbMutex);
        sqlDB->db = (sqlite3 *)sqlDB->db;
        ret = sqlite3_exec(sqlDB->db,sqlInsetTable,NULL,NULL,&errmsg);
        if(ret != SQLITE_OK)
        {
            gseLog(L_ERROR, "%s",sqlInsetTable);
            gseLog(L_ERROR,"ret = %d, inset table fail: %s",ret,errmsg);
        }
        sqlite3_free(errmsg);
        gseMutexUnlock(&dbMutex);
    }
    else if(sqlDB->type == SQL_MYSQL)
    {
#ifdef MYSQL_DEFINE
        sqlDB->db = (MYSQL *)sqlDB->db;
        ret = mysql_query(sqlDB->db, sqlInsetTable);
        if (ret)
        {
            gseLog(L_ERROR,"sqlInsert Error 4 %u: %s", mysql_errno(sqlDB->db), mysql_error(sqlDB->db));
        }
#endif
    }
    else
    {
        ret = -2;
    }
    if(1 == IsUpdateAll && 0 != ret)
    {
        rollBack(sqlDB);
        return ret;
    }

    return ret;
}

int DBUpdate(dbClass *sqlDB, const char *tableName, char *updateSetStr, char *updateWhereStr)
{
    if(sqlDB == NULL || tableName == NULL || updateSetStr == NULL || updateWhereStr == NULL)
    {
        gseLog(L_ERROR,"*db is NULL");
        return -1;
    }
    if(strlen(updateSetStr) >= 1)
        updateSetStr[strlen(updateSetStr)-1]='\0';
    if(strlen(updateWhereStr) >= 3)
        updateWhereStr[strlen(updateWhereStr)-3]='\0';
    char *errmsg = 0;
    int ret = 0;
    char sqlUpdateTable[MAX_SQLSTR]={0};
    sprintf(sqlUpdateTable, "update %s set %s where %s", tableName, updateSetStr, updateWhereStr);
    //update tb_cardID set cardNum=1241243423,password='323443' where cardID=1 and endDate=2013;
    memset(updateSetStr, 0, strlen(updateSetStr));
    memset(updateWhereStr, 0, strlen(updateWhereStr));

    if(sqlDB->type == SQL_SQLITE3)
    {
        gseMutexLock(&dbMutex);
        sqlDB->db = (sqlite3 *)sqlDB->db;
        ret = sqlite3_exec(sqlDB->db,sqlUpdateTable,NULL,NULL,&errmsg);
        if(ret != SQLITE_OK)
        {
            gseLog(L_ERROR, "%s",sqlUpdateTable);
            gseLog(L_ERROR,"ret = %d, update table fail: %s", ret, errmsg);
        }
        sqlite3_free(errmsg);
        gseMutexUnlock(&dbMutex);
    }
    else if(sqlDB->type == SQL_MYSQL)
    {
#ifdef MYSQL_DEFINE
        sqlDB->db = (MYSQL *)sqlDB->db;
        ret = mysql_query(sqlDB->db, sqlUpdateTable);
        if (ret)
        {
            gseLog(L_ERROR,"sqlUpdate Error 4 %u: %s", mysql_errno(sqlDB->db), mysql_error(sqlDB->db));
        }
#endif
    }
    else
    {
        ret = -2;
    }
    if(1 == IsUpdateAll && 0 != ret)
    {
        rollBack(sqlDB);
        return ret;
    }

    return ret;
}

int DBSearch(dbClass *sqlDB, const char *tableName, char *searchWhereStr, char (*returnValue)[SEARCH_MAXLEN])
{
    if(sqlDB == NULL || tableName == NULL || searchWhereStr == NULL)
    {
        gseLog(L_ERROR,"*db is NULL");
        return -1;
    }
    char *errmsg = 0;
    int ret = 0;
    char sqlSearchTable[MAX_SQLSTR]={0};
    int i;
    int nRow=0,nColumn=0;

    if(strlen(searchWhereStr) >= 3)
        searchWhereStr[strlen(searchWhereStr)-3]='\0';
    sprintf(sqlSearchTable, "select * from %s where %s",tableName,searchWhereStr);
    //select * from tb_cardID where cardNum=323435;
    memset(searchWhereStr, 0, strlen(searchWhereStr));

    if(sqlDB->type == SQL_SQLITE3)
    {
        gseMutexLock(&dbMutex);
        sqlDB->db = (sqlite3 *)sqlDB->db;
        char **azResult;
        ret = sqlite3_get_table(sqlDB->db, sqlSearchTable, &azResult, &nRow, &nColumn,&errmsg);
        if(ret != SQLITE_OK)
        {
            gseLog(L_ERROR, "%s",sqlSearchTable);
            gseLog(L_ERROR,"ret = %d, search table fail: %s", ret, errmsg);
        }
//      gseLog(L_INFO,"row:%d column=%d",nRow, nColumn);
        for(i=nColumn;i<(nRow+1)*nColumn;i++)
        {
//          printf("azResult[%d] = %s\n", i, azResult[i]);
            if(azResult[i] != NULL && (*returnValue + SEARCH_MAXLEN*(i-nColumn)) != NULL)
                strcpy(*returnValue + SEARCH_MAXLEN*(i-nColumn), azResult[i]);
        }
        sqlite3_free_table(azResult);
        sqlite3_free(errmsg);
        gseMutexUnlock(&dbMutex);
        if(0 == nRow)
            return 1;
        else if(1 <= nRow)
            return 0;
    }
    else if(sqlDB->type == SQL_MYSQL)
    {
#ifdef MYSQL_DEFINE
        sqlDB->db = (MYSQL *)sqlDB->db;
        ret = mysql_query(sqlDB->db, sqlSearchTable);
        if (ret)
        {
            gseLog(L_ERROR,"sqlSearch Error 4 %u: %s\n", mysql_errno(sqlDB->db), mysql_error(sqlDB->db));
        }
        MYSQL_RES *result;
        MYSQL_ROW row;
        MYSQL_FIELD *field;
        int num_fields;
        result = mysql_store_result(sqlDB->db);
        num_fields = mysql_num_fields(result);
        while ((row = mysql_fetch_row(result)))
        {
            nRow++;
            for(i = 0; i < num_fields; i++)
            {
                if (i == 0) {
                    while(field = mysql_fetch_field(result)) {
                        printf("%s ", field->name);
                    }
                    printf("\n");
                }
                printf("%s  ", row[i] ? row[i] : "NULL");
            }
        }
        printf("\n");
        mysql_free_result(result);

        if(nRow == 0)
            return 0;
        else
            return nRow;
#endif
    }

    return -2;
}

int DBDelete(dbClass *sqlDB, const char *tableName, char *searchWhereStr)
{
    if(sqlDB == NULL || tableName == NULL || searchWhereStr == NULL)
    {
        gseLog(L_ERROR,"*db is NULL");
        return -1;
    }
    char *errmsg = 0;
    int ret = 0;
    char sqlDeleteTable[MAX_SQLSTR]={0};
    if(strlen(searchWhereStr) >= 3)
    {
        searchWhereStr[strlen(searchWhereStr)-3]='\0';
        sprintf(sqlDeleteTable, "delete from %s where %s", tableName, searchWhereStr);
        memset(searchWhereStr, 0, strlen(searchWhereStr));
    }
    else if(strlen(searchWhereStr) == 0)
        sprintf(sqlDeleteTable, "delete from %s", tableName);

    //delete from tb_cardID where cardID=1;
//  gseLog(L_DEBUG, "%s",sqlDeleteTable);

    if(sqlDB->type == SQL_SQLITE3)
    {
        gseMutexLock(&dbMutex);
        sqlDB->db = (sqlite3 *)sqlDB->db;
        ret = sqlite3_exec(sqlDB->db,sqlDeleteTable,NULL,NULL,&errmsg);
        if(ret != SQLITE_OK)
        {
            gseLog(L_ERROR,"ret = %d, delete table fail: %s", ret, errmsg);
        }
        sqlite3_free(errmsg);
        needVacuum = 1;
#if 0
        if (iDelCount++ > FREE_NUM)
        {
            iDelCount = 0;
            ret = sqlite3_exec(sqlDB->db,"vacuum",NULL,NULL,&errmsg);
            if(ret != SQLITE_OK)
            {
                gseLog(L_ERROR,"ret = %d, vacuum fail: %s", ret, errmsg);
            }
            sqlite3_free(errmsg);
        }
#endif
        gseMutexUnlock(&dbMutex);
    }
    else if(sqlDB->type == SQL_MYSQL)
    {
#ifdef MYSQL_DEFINE
        sqlDB->db = (MYSQL *)sqlDB->db;
        ret = mysql_query(sqlDB->db, sqlDeleteTable);
        if (ret)
        {
            printf("sqlDelete Error %u: %s\n", mysql_errno(sqlDB->db), mysql_error(sqlDB->db));
        }
#endif
    }
    else
    {
        ret = -2;
    }
    if(1 == IsUpdateAll && 0 != ret)
    {
        rollBack(sqlDB);
        return ret;
    }

    return ret;
}

int DBVacuum(dbClass *sqlDB)
{
    if(sqlDB == NULL)
    {
        gseLog(L_ERROR,"*db is NULL");
        return -1;
    }
    char *errmsg = 0;
    int ret = 0;
    if(sqlDB->type == SQL_SQLITE3 && 1 == needVacuum)
    {
        gseMutexLock(&dbMutex);
        sqlDB->db = (sqlite3 *)sqlDB->db;
        ret = sqlite3_exec(sqlDB->db,"vacuum",NULL,NULL,&errmsg);
        if(ret != SQLITE_OK)
        {
            gseLog(L_ERROR,"ret = %d, vacuum fail: %s", ret, errmsg);
        }
        else
        {
            needVacuum = 0;
        }
        sqlite3_free(errmsg);
        gseMutexUnlock(&dbMutex);
    }
    return ret;
}

int DBIndex(dbClass *sqlDB, const char *tableName, char *indexName, char *columnName)
{
    if(sqlDB == NULL || tableName == NULL || indexName == NULL || columnName == NULL)
    {
        gseLog(L_ERROR,"SQLITE_Index NULL *p"); 
        return -1;
    }
    int ret = 0;
    char *errmsg = 0;
    char sqlCreateIndex[MAX_SQLSTR]={0};
    sprintf(sqlCreateIndex, "create index %s on %s(%s)", indexName, tableName, columnName);
//  gseLog(L_DEBUG, "%s",sqlCreateIndex);

    if(sqlDB->type == SQL_SQLITE3)
    {
        sqlDB->db = (sqlite3 *)sqlDB->db;
        ret = sqlite3_exec(sqlDB->db,sqlCreateIndex,NULL,NULL,&errmsg);
        if(ret != SQLITE_OK)
        {
            gseLog(L_ERROR,"ret = %d, index table fail: %s", ret, errmsg);
        }
        sqlite3_free(errmsg);
    }
    else if(sqlDB->type == SQL_MYSQL)
    {
#ifdef MYSQL_DEFINE
        sqlDB->db = (MYSQL *)sqlDB->db;
        ret = mysql_query(sqlDB->db, sqlCreateIndex);
        if (ret)
        {
            printf("sqlIndex Error %u: %s\n", mysql_errno(sqlDB->db), mysql_error(sqlDB->db));
        }
#endif
    }

    return ret;
}

int DBGetIdKey(dbClass *sqlDB, const char *tableName, const char *keyName, char (*returnValue)[ID_KEYLEN])
{
    if(sqlDB == NULL || tableName == NULL || keyName== NULL)
    {
        gseLog(L_ERROR,"*db is NULL");
        return -1;
    }
    char *errmsg = 0;
    int ret = 0;
    char sqlSearchTable[MAX_SQLSTR]={0};
    int i;
    int nRow=0,nColumn=0;

    sprintf(sqlSearchTable, "select %s from %s", keyName, tableName);

    if(sqlDB->type == SQL_SQLITE3)
    {
        gseMutexLock(&dbMutex);
        sqlDB->db = (sqlite3 *)sqlDB->db;
        char **azResult;
        ret = sqlite3_get_table(sqlDB->db, sqlSearchTable, &azResult, &nRow, &nColumn,&errmsg);
        if(ret != SQLITE_OK)
        {
            gseLog(L_ERROR, "%s",sqlSearchTable);
            gseLog(L_ERROR,"ret = %d, search table fail: %s", ret, errmsg);
        }
//      gseLog(L_INFO,"row:%d column=%d",nRow, nColumn);
        for(i=nColumn;i<(nRow+1)*nColumn;i++)
        {
//          printf("azResult[%d] = %s\n", i, azResult[i]);
            if(azResult[i] != NULL && (*returnValue + ID_KEYLEN*(i-nColumn)) != NULL)
                strcpy(*returnValue + ID_KEYLEN*(i-nColumn), azResult[i]);
            else
                break;
        }
        sqlite3_free_table(azResult);
        sqlite3_free(errmsg);
        gseMutexUnlock(&dbMutex);
        if(nRow == 0)
            return 0;
        else
            return nRow;
    }
    else if(sqlDB->type == SQL_MYSQL)
    {
#ifdef MYSQL_DEFINE
        sqlDB->db = (MYSQL *)sqlDB->db;
        ret = mysql_query(sqlDB->db, sqlSearchTable);
        if (ret)
        {
            gseLog(L_ERROR,"sqlSearch Error 4 %u: %s\n", mysql_errno(sqlDB->db), mysql_error(sqlDB->db));
        }
        MYSQL_RES *result;
        MYSQL_ROW row;
        MYSQL_FIELD *field;
        int num_fields;
        result = mysql_store_result(sqlDB->db);
        num_fields = mysql_num_fields(result);
        while ((row = mysql_fetch_row(result)))
        {
            nRow++;
            for(i = 0; i < num_fields; i++)
            {
                if (i == 0) {
                    while(field = mysql_fetch_field(result)) {
                        printf("%s ", field->name);
                    }
                    printf("\n");
                }
                printf("%s  ", row[i] ? row[i] : "NULL");
            }
        }
        printf("\n");
        mysql_free_result(result);

        if(nRow == 0)
            return 0;
        else
            return nRow;
#endif
    }

    return -2;
}

int DBExecSql(dbClass *sqlDB, const char *sqlStr)
{
    if(sqlDB == NULL || sqlStr == NULL)
    {
        gseLog(L_ERROR,"*db is NULL");
        return -1;
    }
    char *errmsg = 0;
    int ret = 0;

    if(sqlDB->type == SQL_SQLITE3)
    {
        sqlDB->db = (sqlite3 *)sqlDB->db;
        ret = sqlite3_exec(sqlDB->db,sqlStr,NULL,NULL,&errmsg);
        if(ret != SQLITE_OK)
        {
            gseLog(L_ERROR,"ret = %d, exec sql(%s) fail: %s", ret, sqlStr, errmsg);
        }
        sqlite3_free(errmsg);
    }
    else if(sqlDB->type == SQL_MYSQL)
    {

    }

    return ret;
}

int dbAddColumn(char *createString, const char *keyName, const char *keyClass)
{
    if(createString == NULL || keyName == NULL || keyClass == NULL)
        return -1;
    char tmpKey[128];
    sprintf(tmpKey, "%s %s,", keyName, keyClass);
    strcat(createString, tmpKey);
    return 0;
}

int dbInsertColumn(char *insertString, char *value)
{
    if(insertString == NULL || value == NULL)
        return -1;
    strcat(insertString,value);
    strcat(insertString,",");
    return 0;
}

int dbUpdateSet(char *updateSetStr, const char *setKey, char *setValue)
{
    if(updateSetStr == NULL || setKey == NULL || setValue == NULL)
        return -1;
    char tmpStr[128]={0};
    sprintf(tmpStr, " %s=%s,", setKey, setValue);
    strcat(updateSetStr, tmpStr);
    return 0;

}

int dbSearchWhere(char *searchWhereStr, const char *whereKey, char *whereValue)
{
    if(searchWhereStr == NULL || whereKey == NULL || whereValue == NULL)
        return -1;
    char tmpStr[128]={0};
    sprintf(tmpStr, " %s=%s and", whereKey, whereValue);
    strcat(searchWhereStr , tmpStr);
    return 0;
}

int setFlagIsUpdateAll(dbClass *sqlDB, int n)
{
    int ret= 0;
    IsUpdateAll = n;
    if(-1 == IsUpdateAll)
        ret = rollBack(sqlDB);
    return ret;
}

int getFlagIsUpdateAll()
{
    return IsUpdateAll;
}

int beginExclusive(dbClass *sqlDB)
{
    int ret=0;
    char *errmsg = 0;
    sqlDB->db = (sqlite3 *)sqlDB->db;
    ret = sqlite3_exec(sqlDB->db,"BEGIN EXCLUSIVE", NULL,NULL, &errmsg);    
    if(ret != SQLITE_OK)
    {
        gseLog(L_ERROR,"ret = %d, BEGIN EXCLUSIVE: %s", ret, errmsg);
    }
    sqlite3_free(errmsg);

    return ret;
}

int commitSQL(dbClass *sqlDB)
{
    int ret=0;
    char *errmsg = 0;
    sqlDB->db = (sqlite3 *)sqlDB->db;
    ret=sqlite3_exec(sqlDB->db,"COMMIT", NULL,NULL, &errmsg);
    if(ret != SQLITE_OK)
    {
        gseLog(L_ERROR,"ret = %d, COMMIT: %s", ret, errmsg);
    }
    sqlite3_free(errmsg);

    return ret;
}

int rollBack(dbClass *sqlDB)
{
    int ret=0;
    char *errmsg = 0;
    sqlDB->db = (sqlite3 *)sqlDB->db;
    ret=sqlite3_exec(sqlDB->db,"ROLLBACK", NULL,NULL, &errmsg);
    if(ret != SQLITE_OK)
    {
        gseLog(L_ERROR,"ret = %d, ROLLBACK: %s", ret, errmsg);
    }
    sqlite3_free(errmsg);
    return ret;
}

#ifdef MAIN_TEST
void main()
{
    char createValueStr[MAX_SQLSTR]={0};
    char insertString[MAX_SQLSTR]={0};
    char updateSetStr[MAX_SQLSTR]={0};
    char searchWhereStr[MAX_SQLSTR]={0};
    char *dbFileName="lkdb";
    char *tableName="tb";
    char *colList[]={"ID","names","sexsex"};
    int ret=0;

    timeLog();
    dbClass sqlDB;
    sqlDB.type = SQL_SQLITE3;
    DBOpen(&sqlDB, dbFileName, NULL, NULL, NULL);

//  sqlDB.type = SQL_MYSQL;
//  DBOpen(&sqlDB, dbFileName, "localhost", "root", "mima");
#if 1
    dbAddColumn(createValueStr, colList[0], PRIMAY_KEY);
    dbAddColumn(createValueStr, colList[1], NVARCHAR_32);
    dbAddColumn(createValueStr, colList[2], NVARCHAR_32);
    DBCreate(&sqlDB, tableName, createValueStr);

    dbInsertColumn(insertString, "1");
    dbInsertColumn(insertString, "'y_jg'");
    dbInsertColumn(insertString, "'man'");
    DBInsert(&sqlDB,tableName,insertString);
    dbInsertColumn(insertString, "2");
    dbInsertColumn(insertString, "'lk'");
    dbInsertColumn(insertString, "'man'");
    DBInsert(&sqlDB,tableName,insertString);
    dbInsertColumn(insertString, "3");
    dbInsertColumn(insertString, "'fqq'");
    dbInsertColumn(insertString, "'woman'");
    DBInsert(&sqlDB,tableName,insertString);
    dbInsertColumn(insertString, "4");
    dbInsertColumn(insertString, "'xf'");
    dbInsertColumn(insertString, "'man'");
    DBInsert(&sqlDB,tableName,insertString);
#endif
    dbUpdateSet(updateSetStr,"names", "'xxxx'");
    dbSearchWhere(searchWhereStr,"id","3");
    DBUpdate(&sqlDB,tableName,updateSetStr,searchWhereStr);
    DBClose(&sqlDB);

    timeLog();

}
#endif

本站声明：本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

上一篇：MySQL中EXPLAIN的解释_MySQL 下一篇：用SQL命令查看Mysql数据库大小_MySQL

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

AI编程开发AI聊天问答
豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

AI编程开发AI大模型
通义千问
通义千问

阿里巴巴推出的全能AI助手

AI编程开发Agent智能体
腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文档处理Excel 表格
文心一言
文心一言

文心一言是百度开发的AI聊天机器人，通过对话可以生成各种形式的内容。

AI编程开发AI文本写作
讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具，可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

AI文本写作中文写作
即梦AI
即梦AI

一站式AI创作平台，免费AI图片和视频生成。

图片拼接图画生成
ChatGPT
ChatGPT

最最强大的AI聊天机器人程序，ChatGPT不单是聊天机器人，还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

AI编程开发AI文本写作
智谱清言 - 免费全能的AI助手
智谱清言 - 免费全能的AI助手

智谱清言 - 免费全能的AI助手

AI编程开发Agent智能体

相关专题

更多
Golang 测试体系与代码质量保障：工程级可靠性建设
Golang 测试体系与代码质量保障：工程级可靠性建设

Go语言测试体系与代码质量保障聚焦于构建工程级可靠性系统。本专题深入解析Go的测试工具链（如go test）、单元测试、集成测试及端到端测试实践，结合代码覆盖率分析、静态代码扫描（如go vet）和动态分析工具，建立全链路质量监控机制。通过自动化测试框架、持续集成（CI）流水线配置及代码审查规范，实现测试用例管理、缺陷追踪与质量门禁控制，确保代码健壮性与可维护性，为高可靠性工程系统提供质量保障。

46

2026.02.28

Golang 工程化架构设计：可维护与可演进系统构建
Golang 工程化架构设计：可维护与可演进系统构建

Go语言工程化架构设计专注于构建高可维护性、可演进的企业级系统。本专题深入探讨Go项目的目录结构设计、模块划分、依赖管理等核心架构原则，涵盖微服务架构、领域驱动设计(DDD)在Go中的实践应用。通过实战案例解析接口抽象、错误处理、配置管理、日志监控等关键工程化技术，帮助开发者掌握构建稳定、可扩展Go应用的最佳实践方法。

41

2026.02.28

Golang 性能分析与运行时机制：构建高性能程序
Golang 性能分析与运行时机制：构建高性能程序

Go语言以其高效的并发模型和优异的性能表现广泛应用于高并发、高性能场景。其运行时机制包括 Goroutine 调度、内存管理、垃圾回收等方面，深入理解这些机制有助于编写更高效稳定的程序。本专题将系统讲解 Golang 的性能分析工具使用、常见性能瓶颈定位及优化策略，并结合实际案例剖析 Go 程序的运行时行为，帮助开发者掌握构建高性能应用的关键技能。

37

2026.02.28

Golang 并发编程模型与工程实践：从语言特性到系统性能
Golang 并发编程模型与工程实践：从语言特性到系统性能

本专题系统讲解 Golang 并发编程模型，从语言级特性出发，深入理解 goroutine、channel 与调度机制。结合工程实践，分析并发设计模式、性能瓶颈与资源控制策略，帮助将并发能力有效转化为稳定、可扩展的系统性能优势。

21

2026.02.27

Golang 高级特性与最佳实践：提升代码艺术
Golang 高级特性与最佳实践：提升代码艺术

本专题深入剖析 Golang 的高级特性与工程级最佳实践，涵盖并发模型、内存管理、接口设计与错误处理策略。通过真实场景与代码对比，引导从“可运行”走向“高质量”，帮助构建高性能、可扩展、易维护的优雅 Go 代码体系。

18

2026.02.27

Golang 测试与调试专题：确保代码可靠性
Golang 测试与调试专题：确保代码可靠性

本专题聚焦 Golang 的测试与调试体系，系统讲解单元测试、表驱动测试、基准测试与覆盖率分析方法，并深入剖析调试工具与常见问题定位思路。通过实践示例，引导建立可验证、可回归的工程习惯，从而持续提升代码可靠性与可维护性。

3

2026.02.27

漫蛙app官网链接入口
漫蛙app官网链接入口

漫蛙App官网提供多条稳定入口，包括 https://manwa.me、https

245

2026.02.27

deepseek在线提问
deepseek在线提问

本合集汇总了DeepSeek在线提问技巧与免登录使用入口，助你快速上手AI对话、写作、分析等功能。阅读专题下面的文章了解更多详细内容。

21

2026.02.27

AO3官网直接进入
AO3官网直接进入

AO3官网最新入口合集，汇总2026年可用官方及镜像链接，助你快速稳定访问Archive of Our Own平台。阅读专题下面的文章了解更多详细内容。

403

2026.02.27

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

相关下载

更多
php商城系统
淘源码商城PHP淘宝查信誉
PHP房产程序[BBWPS]
PHP简约自动发卡平台个人版
ERMEB域名PHP离线网络授权系统
Difeye-敏捷的轻量级PHP框架
大泉州汽车网PHP整站程序

精品课程

更多
相关推荐
/
热门推荐
/
最新课程

最新文章

更多
mysql如何实现搜索补全_mysql前缀匹配查询优化
mysql如何恢复单表数据_mysql单表恢复技巧
mysql事务回滚时锁会释放吗_mysql锁释放机制解析
mysql如何处理mysql.sock丢失无法登录_mysql套接字文件恢复
mysql使用mysqldump备份数据库_mysql逻辑备份教程
mysql如何实现文章分类功能_mysql多对一关联实践
mysql如何使用like模糊查询_mysql模糊匹配方法
mysql主从复制数据丢失如何恢复_恢复策略解析
mysql升级过程中的常见问题如何解决_mysql故障排查指南
mysql使用EXPLAIN分析查询执行计划
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网：公益在线php培训，帮助PHP学习者快速成长！
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号

  • PHP学习

  • 技术支持

  • 返回顶部