loadrunner 实现对数据库操作，以及从数据库取值

#define MYSQLSERVER  "localhost"

#define MYSQLUSERNAME  "root"

#define MYSQLPASSWORD  "root"

#define MYSQLDB  "information"

#define MYSQLPORT  "3306"

#include "Ptt_Mysql.h"

char sqQuery [ 512 ];  //定义一个字符数组存储查询的sql语句

int i = 0 ;

MYSQL  *Mconn ;  //mysql连接字符串

char * name ;

char * pwd ;

int count = 0 ;

vuser_init ()

{

lr_load_dll ( "libmysql.dll" );

Mconn  =  lr_mysql_connect (MYSQLSERVER , MYSQLUSERNAME , MYSQLPASSWORD , MYSQLDB ,  atoi (MYSQLPORT )); //创建连接

return  0 ;

}

Action_model()

{

sprintf(sqQuery, "SELECT * FROM user; ");//查询

lr_mysql_query(Mconn, sqQuery);//执行

count=mysql_affected_rows(Mconn);//受影响的行数

for(i=0;i<count;i++){

    lr_save_string(row[0][i].cell, "sUsername");

    lr_save_string(row[1][i].cell, "sPassword");

    lr_output_message(lr_eval_string("{sUsername}"));

    lr_output_message(lr_eval_string("{sPassword}"));

}

 //query_result = mysql_use_result(Mconn);

//sprintf(sqQuery,"INSERT INTO user VALUES('15000000000','222222');");//插入

//lr_mysql_query(Mconn, sqQuery);

//sprintf(sqQuery,"UPDATE test1 SET uname='aaa' WHERE id=1; ");//更新

//lr_mysql_query(Mconn, sqQuery);

//sprintf(sqQuery,"DELETE FROM test1 WHERE id=1;");//删除

//lr_mysql_query(Mconn, sqQuery);

return 0;

}

vuser_end()

{

    //断开数据库连接

    mysql_close(Mconn);

    return 0;

}