loadrunner连接mysql数据库执行sql语句
第一步：将本文附件中的bin和include文件夹下的文件分别拷贝到loadrunner安装目录中的bin和include文件夹下。
第二步：新建脚本，协议选：Web-HTTP/HTML
第三步：在脚本中，将以下代码添加到Action()。
Action()
{
int rc; //定义状态变量,0表示成功，非0表示失败
int db_connection; //定义初始化状态
int query_result; //定义查询结果状态
char *server = "101.200.115.54"; // 数据库的ip地址
char *user = "tst"; // 数据库访问用户名
char *password = "Huititst77dev"; // 密码
char *database = "gamedb"; // 数据库名称
int port = 3306; // 访问端口
int unix_socket = NULL;
int flags = 0;
char** result_row; //定义查询的结果集
rc=lr_load_dll("libmysql.dll");
if (rc!=0) {
lr_error_message("不能加载dll文件");
lr_error_message("%s",mysql_error(db_connection));//输出加载失败错误信息
mysql_close(db_connection); //关闭链接
lr_abort(); //退出
}
db_connection=mysql_init(NULL); //初始化mysql连接
if (db_connection==NULL ) { //如果链接状态为空就退出
lr_abort();
}
rc=mysql_real_connect(db_connection,server,user,password,database,port,unix_socket,flags);//连接到mysql数据库
if (rc==NULL) { //如果链接结果为NULL 输出错误
lr_error_message("%s",mysql_error(db_connection));
mysql_close(db_connection);
lr_abort();
}
rc=mysql_query(db_connection,"SELECT * FROM gamedb.game where id='faf5731c37ef91d4';");//执行查询语句
if (rc!=0) { //输出查询失败的信息
lr_error_message("%s",mysql_error(db_connection));
mysql_close(db_connection);
lr_abort();
}
query_result=mysql_use_result(db_connection);//查询数据表
while (result_row=(char**)mysql_fetch_row(query_result)) {
lr_save_string(result_row,"game"); //将获取的数据保存为参数game
lr_output_message("game is %s",lr_eval_string("{game}")); //将所在行的数据输出
if ( result_row==NULL) { //如果查询结果行为空，就关闭并退出
lr_error_message("没有查询到结果");
mysql_free_result(query_result);
mysql_close(db_connection);
lr_abort();
}
}
mysql_free_result(query_result);//释放结果集
mysql_close(db_connection); //关闭数据库连接
return 0;
}
vuser_init()和vuser_end()不需要动
页:
[1]