关于LR接收Mysql查询内容的函数

wyhuyawangyu

LR中写个脚本，里面包含一条查询Mysql的语句，显示小修改了下，但是平均事物响应时间远远小于用navicat上查询出的时间。（前一个是2秒多，后面查是24秒左右），后来看脚本，发现脚本中只有查询的语句，没有等待Mysql返回结果的语句，不知道LR中有没这样的函数：得到Mysql的查询结果。或者说我得换个思路了。。。

qinlele212

我现在也遇到对数据库直接测试，求解

liuxueyi

mysql_use_result

liuxueyi

查询后返回的数据，保存错了吧

liuxueyi

这个脚本我知道，那个库我也知道，不明白楼主想干嘛。

wyhuyawangyu

回复 5# 云层


    我改用java的那个方法了，果然好用~

wyhuyawangyu

回复 5# 云层


    我们BOSS的想法是直接压数据库，这样得到的结果比较准确，所以找了个这样的脚本。=。=

云层

我用Java方式连Mysql没这个问题，dll的调用不太清楚那个函数叫什么，应该是可以返回值的

wyhuyawangyu

wyhuyawangyu

贴个代码，是不是在｛｝中加个什么函数就行呢
  rc = mysql_query(db_connection, lr_eval_string("{paramInsertQuery}"));
        if (rc = 0) {

        }

wyhuyawangyu

int rc;
  int db_connection; // 数据库连接
  int query_result; // 查询结果集 MYSQL_RES
  char** result_row; // 查询的数据衕

  char *server = "192.168.1.250";
  char *user = "root";
  char *password = "*****";
  char *database = "****";
  int port = 3306;
  int unix_socket = NULL;
  int flags = 0;

  // 找到libmysql.dll的所在位置.
  rc = lr_load_dll("C:\\Program Files\\MySQL\\MySQL Server 5.5\\lib\\libmySQL.dll");
  if (rc != 0) {
    lr_error_message("Could not load libmysql.dll");
    lr_abort();
  }

  // 创建MySQL对象
  db_connection = mysql_init(NULL);
  if (db_connection == NULL) {
    lr_error_message("Insufficient memory");
    lr_abort();
  }

  // 连接到MySQL数据库
  rc = mysql_real_connect(db_connection, server, user, password, database, port, unix_socket, flags);
  while(rc == NULL){
          rc = mysql_real_connect(db_connection, server, user, password, database, port, unix_socket, flags);
  }

  // 从数据库查数据
  lr_save_string (lr_eval_string("SELECT SQL_NO_CACHE   a.*,c.CN_NAME,b.* from CRM_PLATFORM_CUSTOMER "
                                                                 "a LEFT OUTER JOIN ST_COMPANY_CATEOGRY_SUM b ON "
                                                                 "a.CR_COMPANY_ID=b.CR_COMPANY_ID LEFT OUTER JOIN MD_CATEGORY "
                                                                 "c ON b.CR_CATEGORY3_ID=c.CN_ID WHERE a.CR_MGR_GROUP_ID like'001003%' "
                                                                 "and b.CN_COUNT>0;"),"paramInsertQuery");
  rc = mysql_query(db_connection, lr_eval_string("{paramInsertQuery}"));
        if (rc = 0) {

        }

// 释放MySQL资源
  mysql_close(db_connection);
        return 0;