推荐mysql编程入门之多查询执行的C API处理方法
发布时间：2023-08-18 15:24:10 所属栏目：MySql教程 来源：
导读：下文内容主要给大家带来mysql编程入门之多查询执行的C API处理方法，这里所讲到的知识，与书籍略有不同，都是亿速云专业技术人员在与用户接触过程中，总结出来的，具有一定的经验分享价值，希望给广大读者带来帮助。
|
下文内容主要给大家带来mysql编程入门之多查询执行的C API处理方法，这里所讲到的知识，与书籍略有不同，都是亿速云专业技术人员在与用户接触过程中，总结出来的，具有一定的经验分享价值，希望给广大读者带来帮助。 多查询执行的C API处理 n支持在单个字符串中指定的多语句的执行。要想与给定的连接一起使用该功能，打开连接时，必须将标志参数中的CLIENT_MULTI_STATEMENTS选项指定给mysql_real_connect()。也可以通过调用mysql_set_server_option(MYSQL_OPTION_MULTI_STATEMENTS_ON)，为已有的连接设置它 多查询就几个点 CLIENT_MULTI_STATEMENTS选项指定 mysql_next_result int mysql_next_result(MYSQL *mysql) mysql编程入门之多查询执行的C API处理方法 描述 如果存在多个查询结果，mysql_next_result()将读取下一个查询结果，并将状态返回给应用程序。 如果前面的查询返回了结果集，必须为其调用mysql_free_result()。 调用了mysql_next_result()后，连接状态就像你已为下一查询调用了mysql_real_query()或mysql_query()时的一样。这意味着你能调用mysql_store_result()、mysql_warning_count()、mysql_affected_rows()等等。 如果mysql_next_result()返回错误，将不执行任何其他语句，也不会获取任何更多的结果 返回值 描述 0成功并有多个结果。 -1 成功但没有多个结果。 0出错 #include <stdio.h> #include <stdlib.h> #include <string.h> #include <mysql/mysql.h> int process_result_set(MYSQL mysql, MYSQL_RES result) { int ret = 0, i = 0; unsigned int num = 0; if (mysql==NULL || result==NULL) { ret = 0; printf("func process_result_set() err:%d, check if (mysql==NULL || result==NULL) \n", ret); return ret; } num = mysql_field_count(mysql) ; //求表头 MYSQL_FIELD *fields = mysql_fetch_fields(result); for (i = 0; i<num; i++) { printf("%s\t", fields[i].name); } printf("\n"); //按照行 求内容 MYSQL_ROW row = NULL; while ( row = mysql_fetch_row(result) ) { for (i=0; i<num; i++) { printf("%s\t", row[i]); } printf("\n"); } return 0; } int main() { int ret = 0; int status = 0; MYSQL *mysql; MYSQL *connect = NULL; MYSQL_RES *result ; mysql = mysql_init(NULL) ; if (mysql == NULL) { ret = mysql_errno(mysql) ; printf("func mysql_init() err \n"); return ret; } printf("func mysql_init() ok \n"); connect = mysql_real_connect(mysql, "localhost", "root", "123456", "mydb2", 0, NULL, CLIENT_MULTI_STATEMENTS); if (connect == NULL) { ret = mysql_errno(mysql) ; printf("func mysql_init() err \n"); return ret; } /* execute multiple statements */ status = mysql_query(mysql, "DROP TABLE IF EXISTS test_table;\ CREATE TABLE test_table(id INT);\ INSERT INTO test_table VALUES(10);\ UPDATE test_table SET id=20 WHERE id=10;\ SELECT * FROM test_table;\ DROP TABLE test_table"); if (status) { printf("Could not execute statement(s)"); mysql_close(mysql); exit(0); } /* process each statement result */ do { /* did current statement return data? */ result = mysql_store_result(mysql); if (result) //select语句 { /* yes; process rows and free the result set */ //打桩（也可叫占位函数） process_result_set(mysql, result); mysql_free_result(result); } else /* no result set or error */ { if (mysql_field_count(mysql) == 0)//返回作用在连接上的最近查询的列数，此为非查询，故为0 { printf("%lld rows affected\n", mysql_affected_rows(mysql)); } else /* some error occurred */ { printf("Could not retrieve result set\n"); break; } } /* more results? -1 = no, >0 = error, 0 = yes (keep looping) */ if ((status = mysql_next_result(mysql)) > 0) printf("Could not execute statement\n"); } while (status == 0); mysql_close(connect); printf("hello...\n"); return ret; } 二进制协议允许你使用MYSQL_TIME结构发送和接受日期和时间值（DATE、TIME、DATETIME和TIMESTAMP） 要想发送临时数据值，可使用mysql_stmt_prepare()创建预处理语句。然后，在调用mysql_stmt_execute()执行语句之前，可采用下述步骤设置每个临时参数： 在与数据值相关的MYSQL_BIND结构中，将buffer_type成员设置为相应的类型，该类型指明了发送的临时值类型。对于DATE、TIME、DATETIME或TIMESTAMP值，将buffer_type分别设置为MYSQL_TYPE_DATE、MYSQL_TYPE_TIME、MYSQL_TYPE_DATETIME或MYSQL_TYPE_TIMESTAMP。 将MYSQL_BIND结构的缓冲成员设置为用于传递临时值的MYSQL_TIME结构的地址。 填充MYSQL_TIME结构的成员，使之与打算传递的临时支的类型相符。 使用mysql_stmt_bind_param()将参数数据绑定到语句。然后可调用mysql_stmt_execute()。 要想检索临时值，可采用类似的步骤，但应将buffer_type成员设置为打算接受的值的类型，并将缓冲成员设为应将返回值置于其中的MYSQL_TIME结构的地址。调用mysql_stmt_execute()之后，并在获取结果之前，使用mysql_bind_results()将缓冲绑定到语句上。 请看代码： #include <stdio.h> #include <stdlib.h> #include <string.h> #include <dlfcn.h> #include <mysql/mysql.h> #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <string.h> #include <errno.h> #include <termios.h> #include <mysql/mysql.h> int main() { int ret = 0, status = 0; MYSQL mysql; MYSQL_RES result; mysql =mysql_init(NULL); mysql =mysql_real_connect(mysql, "localhost", "root", "123456", "mydb2", 0, NULL, CLIENT_MULTI_STATEMENTS ); if (mysql == NULL) { ret = mysql_errno(mysql); printf("%s", mysql_error(mysql)); printf("func mysql_real_connect() err :%d\n", ret); return ret; } else { printf(" ok......\n"); } MYSQL_TIME ts; MYSQL_BIND bind[3]; MYSQL_STMT *stmt; //注意： // 创建的表语句 // create table test_table (date_field date, time_field time, timestamp_field timestamp ); char query[1024] = "INSERT INTO test_table(date_field, time_field, timestamp_field) VALUES(?,?,?)"; stmt = mysql_stmt_init(mysql); if (!stmt) { fprintf(stderr, " mysql_stmt_init(), out of memory\n"); exit(0); } if (mysql_stmt_prepare(stmt, query, strlen(query))) //向环境句柄中添加sql语言 带有占位符 { fprintf(stderr, "\n mysql_stmt_prepare(), INSERT failed"); fprintf(stderr, "\n %s", mysql_stmt_error(stmt)); exit(0); } /* set up input buffers for all 3 parameters */ bind[0].buffer_type= MYSQL_TYPE_DATE; //设置绑定变量属性 bind[0].buffer= (char *)&ts; bind[0].is_null= 0; bind[0].length= 0; // bind[1]= bind[2]= bind[0]; //... mysql_stmt_bind_param(stmt, bind); /* supply the data to be sent in the ts structure */ ts.year= 2002; ts.month= 02; ts.day= 03; ts.hour= 10; ts.minute= 45; ts.second= 20; mysql_stmt_execute(stmt); // Close the statement // if (mysql_stmt_close(stmt)) { fprintf(stderr, " failed while closing the statement\n"); fprintf(stderr, " %s\n", mysql_stmt_error(stmt)); exit(0); } mysql_close(mysql); （编辑：聊城站长网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
推荐文章
站长推荐
