OceanBase学习记录6|C 相关 API 介绍

本文主要介绍常用的 C API 函数和示例。

C API 函数概览

当前版本 OceanBase Connector/C 所有可用的 C API 函数如下表所示。

有关各接口详细信息，请参见官网文档 《OceanBase Connector/C》 下的 C API 函数概览 章节。

示例

使用基础接口连接数据库，并创建表和更改数据。

mysql_library_init(0, NULL, NULL);
MYSQL *mysql = mysql_init(NULL);

/* 使用 CLIENT_MULTI_STATEMENTS 选项连接服务器 */
if (mysql_real_connect (mysql, host_name, user_name, password,
    db_name, port_num, socket_name, CLIENT_MULTI_STATEMENTS) == NULL)
{
  printf("mysql_real_connect() failed\n");
  mysql_close(mysql);
  mysql_library_end();
  exit(1);
}

/*执行多条语句 */
status = mysql_query(mysql,
                     "DROP TABLE IF EXISTS tbl1;\
                      CREATE TABLE tbl1(id INT);\
                      INSERT INTO tbl1 VALUES(110);\
                      UPDATE tbl1 SET id=120 WHERE id=110;\
                      SELECT * FROM tbl1;\
                      DROP TABLE tbl1");
if (status)
{
  printf("Could not execute statement(s)");
  mysql_close(mysql);
  mysql_library_end();
  exit(0);
}

/* 处理每个语句的结果 */
do {
  /* 当前语句是否返回数据? */
  result = mysql_store_result(mysql);
  if (result)
  {
    /* 是的; 则处理行并释放结果集 */
    process_result_set(mysql, result);
    mysql_free_result(result);
  }
  else          /* 没有结果集或报错 */
  {
    if (mysql_field_count(mysql) == 0)
    {
      printf("%lld rows affected\n",
            mysql_affected_rows(mysql));
    }
    else  /* 发生报错 */
    {
      printf("Could not retrieve result set\n");
      break;
    }
  }
  /* 判断是否有更多结果？ -1 表示否，大于 0 表示报错，等于 0 表示是（即继续循环）*/
  if ((status = mysql_next_result(mysql)) > 0)
    printf("Could not execute statement\n");
} while (status == 0);

mysql_close(mysql);
mysql_library_end();