126 lines
3.9 KiB
C
126 lines
3.9 KiB
C
#include <stdio.h>
|
|
#include <string.h>
|
|
#include "mysql.h"
|
|
#include "test_util.h"
|
|
/*
|
|
*
|
|
*/
|
|
int do_pl_test(MYSQL* mysql) {
|
|
my_log("=========do_pl_test==========");
|
|
const char* create_pl = "create or replace procedure pl_test(x in number, y in out varchar2) "\
|
|
"is begin "\
|
|
" y:='this is a pl test';"\
|
|
"END";
|
|
int ret = 0;
|
|
if (mysql_real_query(mysql, create_pl, strlen(create_pl))) {
|
|
my_log("mysql_real_query failed: %s", mysql_error(mysql));
|
|
ASSERT_EQ(0, -1, "mysql_real_query failed");
|
|
return -1;
|
|
}
|
|
const char* pStatement = "call pl_test(?, ?)";
|
|
MYSQL_STMT *stmt;
|
|
MYSQL_BIND param_bind[2];
|
|
MYSQL_BIND res_bind[2];
|
|
int param_count;
|
|
int id = 8;
|
|
char name[20] = "jh";
|
|
my_ulonglong affected_rows;
|
|
stmt = mysql_stmt_init(mysql);
|
|
if (!stmt) {
|
|
my_log("msyql_stmt_init failed: %s", mysql_error(mysql));
|
|
ASSERT_EQ(0, -1, "mysql_stmt_init failed");
|
|
return -1;
|
|
}
|
|
if (mysql_stmt_prepare(stmt, pStatement, strlen(pStatement))) {
|
|
my_log("mysql_stmt_prepare failed:%s", mysql_error(mysql));
|
|
ASSERT_EQ(0, -1, "mysql_stmt_prepare failed");
|
|
return -1;
|
|
}
|
|
param_count = mysql_stmt_param_count(stmt);
|
|
ASSERT_EQ(param_count, 2, "mysql_stmt_param_count");
|
|
MYSQL_RES *param_result = NULL;
|
|
MYSQL_FIELD *params = NULL;
|
|
if (NULL == (param_result = mysql_stmt_param_metadata(stmt))) {
|
|
my_log("mysql_stmt_param_metadata failed:%s", mysql_stmt_error(stmt));
|
|
} else if (NULL == (params = mysql_fetch_params(param_result))) {
|
|
my_log("mysql_fetch_params failed:%s", mysql_stmt_error(stmt));
|
|
} else {
|
|
ASSERT_EQ(params[1].ob_routine_param_inout, 3, "ob_routine_param_inout");
|
|
}
|
|
memset(param_bind, 0, sizeof(param_bind));
|
|
memset(res_bind, 0, sizeof(res_bind));
|
|
{
|
|
//id
|
|
param_bind[0].buffer_type = MYSQL_TYPE_LONG;
|
|
param_bind[0].buffer = (char*)&id;
|
|
param_bind[0].buffer_length = 0;
|
|
param_bind[0].is_null = 0;
|
|
param_bind[0].length = 0;
|
|
}
|
|
{
|
|
//name
|
|
unsigned long str_len = strlen(name);
|
|
param_bind[1].buffer_type = MYSQL_TYPE_STRING;
|
|
param_bind[1].buffer = (char*)name;
|
|
param_bind[1].buffer_length = str_len;
|
|
param_bind[1].is_null = 0;
|
|
param_bind[1].length = &str_len;
|
|
// bind[1].is_unsigned = 0;
|
|
}
|
|
if (mysql_stmt_bind_param(stmt, param_bind)) {
|
|
my_log("bind failed:%s", mysql_stmt_error(stmt));
|
|
ASSERT_EQ(0, -1, "mysql_stmt_bind_param failed");
|
|
return -1;
|
|
}
|
|
if (mysql_stmt_execute(stmt)) {
|
|
my_log("mysql_stmt_execute insert failed:%s", mysql_stmt_error(stmt));
|
|
ASSERT_EQ(0, -1, "mysql_stmt_execute failed");
|
|
return -1;
|
|
}
|
|
char out_buf[20] = {0};
|
|
res_bind[0].buffer_type = MYSQL_TYPE_STRING;
|
|
res_bind[0].buffer = out_buf;
|
|
res_bind[0].buffer_length = sizeof(out_buf);
|
|
|
|
if (mysql_stmt_bind_result(stmt, res_bind)) {
|
|
my_log("mysql_stmt_bind_result failed:%s", mysql_stmt_error(stmt));
|
|
return -1;
|
|
}
|
|
int i = 1;
|
|
while (mysql_stmt_fetch(stmt) == 0) {
|
|
// my_log("out_buf is %s", out_buf);
|
|
if (strcmp(out_buf, "this is a pl test") == 0) {
|
|
ASSERT_EQ(0, 0, "mysql_stmt_fetch");
|
|
} else {
|
|
ASSERT_EQ(0, -1, "mysql_stmt_fetch");
|
|
}
|
|
}
|
|
if (mysql_stmt_close(stmt)) {
|
|
my_log("mysql_stmt_close faield:%s", mysql_stmt_error(stmt));
|
|
ASSERT_EQ(0, -1, "mysql_stmt_error");
|
|
return -1;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
int main(int argc, char** argv) {
|
|
mysql_library_init(0, NULL, NULL);
|
|
MYSQL *mysql = mysql_init(NULL);
|
|
unsigned int timeout = 3000;
|
|
init_conn_info(OB_ORACLE_MODE);
|
|
mysql_options(mysql, MYSQL_OPT_CONNECT_TIMEOUT, &timeout);
|
|
|
|
if (mysql_real_connect(mysql, DBHOST, DBUSER, DBPASS, DBNAME, DBPORT, DBSOCK, DBPCNT) == NULL)
|
|
{
|
|
my_log("connect failed: %s, host:%s, port:%d, user:%s, pass:%s, dbname:%s",
|
|
mysql_error(mysql),DBHOST, DBPORT, DBUSER, DBPASS, DBNAME);
|
|
mysql_close(mysql);
|
|
mysql_library_end();
|
|
return 0;
|
|
} else {
|
|
my_log("connect %s:%d using %s succ", DBHOST, DBPORT, DBUSER);
|
|
}
|
|
do_pl_test(mysql);
|
|
return 0;
|
|
}
|