LoadRunner访问Mysql数据库_MySQL

int db_connection;

char *server = "192.168.1.100"; // 数据库的ip地址

char *user = "root"; // 数据库访问用户名

char *password = "123456"; // 密码

char *database = "t3db"; // 数据库名称

int port = 3306; // 访问端口

int unix_socket = NULL;

char** result_row;

int query_result;

char szSql[256];

int MySqlInit()

rc = lr_load_dll("libmysql.dll");

db_connection = mysql_init(NULL);

if (db_connection == NULL)

lr_error_message("Insufficient memory");

lr_error_message("Load MySql.dll Error!");

rc = mysql_real_connect(db_connection,server, user, password, database, port, unix_socket, flags);

lr_error_message("connect mysql error! %s",mysql_error(db_connection));

mysql_close(db_connection);

int MySqlUnit()

// 释放MySQL资源

mysql_close(db_connection);

int InsertValue(char* query)

rc = mysql_query(db_connection,query);

lr_error_message("%s", mysql_error(db_connection));

int MySqlQuery(char* szSql)

rc = mysql_query(db_connection,szSql);

lr_error_message("%s",lr_eval_string("?"));

lr_error_message("%s", mysql_error(db_connection));

query_result = mysql_use_result(db_connection);

if (query_result == NULL)

lr_error_message("%s", mysql_error(db_connection));

mysql_free_result(query_result);

result_row = (char **)mysql_fetch_row(query_result);

if (result_row == NULL)

lr_error_message("Did not expect the result set to be empty");

mysql_free_result(query_result);

mysql_free_result(query_result);

MySqlInit(); // 初始化数据库

MySqlUnit(); // 反初始化

int resultValue;

char cIndex[10];

char onceAccount[1024];

char insertQuery[22584];

index = index +1;

// 组合插入数据库的sql语句

strcpy(insertQuery, "INSERT INTO `t3db`.`role`(GroupID, RoleName, Account, BaseInfo, ExtInfo, LastModify) VALUES('1', '");

strcat(insertQuery, lr_eval_string("{Account}"));

strcat(insertQuery, itoa(index, cIndex, 10 ));

strcat(insertQuery, "', 'q1031', '111', '111','2013-02-28 20:42:33')");

strcat(insertQuery, ";/0");

lr_start_transaction("Insert");

resultValue = InsertValue(insertQuery); // 调用插入函数

if(resultValue != 0)

lr_end_transaction("Insert",LR_FAIL);

lr_end_transaction("Insert",LR_PASS);