MySQL打包执行SQL

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了MySQL打包执行SQL，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2462字，纯文字阅读大概需要4分钟。

内容图文

当一次业务处理计算服务和数据库交互较多时，将可能有大量时间浪费在数据传输上，尤其对于计算服务和数据库跨机房或跨地区部署时，浪费的时间会极其可观。为了减少时间浪费可以使用MySQL提供的SQL打包功能。

先来认识两个标记：
CLIENT_MULTI_RESULTS：Tell the server that the client can handle multiple result sets from multiple-statement executions or stored procedures. This flag is automatically enabled if CLIENT_MULTI_STATEMENTS is enabled.
CLIENT_MULTI_STATEMENTS：Tell the server that the client may send multiple statements in a single string (separated by “;”). If this flag is not set, multiple-statement execution is disabled.

接下来通过一个例子了解如何使用MySQL这个功能：

新建表结构：

主要代码：

#include <stdio.h>
#include <string.h>
#include "mysql.h"

int main(int argc, const char* argv[])
{
    bool deal_ok = true;

    MYSQL* db_session = 0;

    // init db
    if (deal_ok)
    {
        db_session = mysql_init(db_session);

        if (0 != db_session)
        {
            printf("init db\n");
        }
        else
        {
            deal_ok = false;
            printf(" init db error\n");
        }
    }

    //connect db
    if (deal_ok)
    {
        char db_host[32] = {"127.0.0.1"};
        char db_user[32] = {"test"};
        char db_pass[32] = {"123456789"};
        unsigned long db_port   = 3306;
        unsigned long conn_flag = CLIENT_MULTI_STATEMENTS | CLIENT_REMEMBER_OPTIONS;

        if (mysql_real_connect(db_session, db_host, db_user, db_pass, 0, db_port, 0, conn_flag))
        {
            printf("connect successed\n");
        }
        else
        {
            deal_ok = false;
            printf("connect error: %s\n", mysql_error(db_session));
        }
    }

    //start transaction
    if (deal_ok)
    {
        int db_ret = mysql_query(db_session, "START TRANSACTION");
        if (0 == db_ret)
        {
            printf("start transaction\n");
        }
        else
        {
            deal_ok = false;
            printf("start transaction error: %s\n", mysql_error(db_session));
        }
    }

    //operate db
    if (deal_ok)
    {
        char db_sql[1024] = {0};
        strcat(db_sql, "INSERT INTO test_db.test(trans_id, comments) VALUES(110, 'test');");
        strcat(db_sql, "UPDATE test_db.test SET comments = 'modify' WHERE trans_id = '108';");

        printf("operate db: %s\n", db_sql);

        int db_ret = mysql_real_query(db_session, db_sql, strlen(db_sql));
        if (0 == db_ret)
        {
            while (0 == db_ret)
            {
                printf("    affected rows : %d\n", (int)mysql_affected_rows(db_session));

                db_ret = mysql_next_result(db_session);
            }
        }
        else
        {
            deal_ok = false;
            printf("\terror: %s\n", mysql_error(db_session));
        }
    }

    //complete transaction
    if (0 != db_session)
    {
        if (deal_ok)
        {
            mysql_commit(db_session);
            printf("commit\n");
        }
        else
        {
            mysql_rollback(db_session);
            printf("rollback\n");
        }

        mysql_close(db_session);
    }
    
    return 0;
}

内容总结

以上是互联网集市为您收集整理的MySQL打包执行SQL全部内容，希望文章能够帮你解决MySQL打包执行SQL所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端