AI 助理
备案控制台
开发者社区 数据库 文章 正文

Loadrunner测试数据库、SQL语句性能

2017-07-10 1855
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，高可用系列 2核4GB
简介：
Action()   
{   
int rc;     
int db_connection; //  数据库 连接   
int query_result; // 查询结果集 MYSQL_RES   
char** result_row; // 查询的数据衕   
     
char *server = "localhost";   
char *user = "root";   
char *password = "123456";   
char *database = " test ";   
int port = 3306;   
int unix_socket = NULL;     
int flags = 0;     
     
// 找到libmysql.dll的所在位置.   
rc = lr_load_dll("C:\\Program Files\\MySQL\\MySQL  Server  5.1\\bin\\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);   
if (rc == NULL) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
     
// 向数据库插入数据   
// 此处的 {ORDER_ID} 是一个参数，简单 测试 时可以用一个常数代替   
lr_save_string (lr_eval_string("INSERT INTO test_data (order_id) VALUES ({ORDER_ID})"),"paramInsertQuery");     
rc = mysql_query(db_connection, lr_eval_string("{paramInsertQuery}"));   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
     
// 从数据库读取一个数据并显示   
rc = mysql_query(db_connection, "SELECT order_id FROM test_data WHERE status IS FALSE LIMIT 1");   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
query_result = mysql_use_result(db_connection);   
if (query_result == NULL) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_free_result(query_result);   
        mysql_close(db_connection);   
        lr_abort();   
}   
// 如果结果集包含多行数据，需要多次调用 mysql_fetch_row 直到返回NULL   
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_close(db_connection);   
        lr_abort();   
}   
// 保存参数，用于删除这行数据   
lr_save_string(result_row[0], "paramOrderID");   
lr_output_message("Order ID is: %s", lr_eval_string("{paramOrderID}"));   
mysql_free_result(query_result);   
     
// 在事务里更新一行数据，需要用InnoDB引擎   
rc = mysql_query(db_connection, "BEGIN"); //启动事务   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
// 使用 "FOR UPDATE" 锁住要更新的数据行   
rc = mysql_query(db_connection, "SELECT order_id FROM test_data WHERE status IS FALSE LIMIT 1 FOR UPDATE");     
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
query_result = mysql_use_result(db_connection);   
if (query_result == NULL) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_free_result(query_result);   
        mysql_close(db_connection);   
        lr_abort();   
}   
result_row = (char **)mysql_fetch_row(query_result);     
if (result_row == NULL) {   
        lr_error_message("没有查询到结果");   
        mysql_free_result(query_result);   
        mysql_close(db_connection);   
        lr_abort();   
}   
lr_save_string(result_row[0], "paramOrderID");   
lr_output_message("Order ID is: %s", lr_eval_string("{paramOrderID}"));   
mysql_free_result(query_result);   
lr_save_string(lr_eval_string("UPDATE test_data SET status=TRUE, date_used=NOW() WHERE order_id='{paramOrderID}'"),"paramUpdateQuery");   
rc = mysql_query(db_connection, lr_eval_string("{paramUpdateQuery}"));   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
rc = mysql_query(db_connection, "COMMIT"); // 提交事务   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
     
// 再次查找数据，应该为空了，因为前面的事务更新了标志   
rc = mysql_query(db_connection, "SELECT order_id FROM test_data WHERE status IS FALSE LIMIT 1");   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
query_result = mysql_use_result(db_connection);   
if (query_result == NULL) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_free_result(query_result);   
        mysql_close(db_connection);   
        lr_abort();   
}   
result_row = (char **)mysql_fetch_row(query_result);   
if (result_row == NULL) {   
        lr_output_message("Result set is empty as expected");   
        mysql_free_result(query_result);   
} else {   
        lr_error_message("Did not expect the result set to contain any rows");   
        mysql_free_result(query_result);   
        mysql_close(db_connection);   
        lr_abort();   
}   
     
// 删除数据   
lr_save_string(lr_eval_string("DELETE FROM test_data WHERE order_id = '{paramOrderID}'"),"paramDeleteQuery");   
rc = mysql_query(db_connection, lr_eval_string("{paramDeleteQuery}"));   
if (rc != 0) {   
        lr_error_message("%s", mysql_error(db_connection));   
        mysql_close(db_connection);   
        lr_abort();   
}   
     
// 释放MySQL资源   
mysql_close(db_connection);   
        return 0;   
}

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

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

// 找到libmysql.dll的所在位置.
rc = lr_load_dll("C:\\Program Files\\MySQL\\MySQL Server 5.1\\bin\\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);
if (rc == NULL) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}

// 向数据库插入数据
// 此处的 {ORDER_ID} 是一个参数，简单测试时可以用一个常数代替
lr_save_string (lr_eval_string("INSERT INTO test_data (order_id) VALUES ({ORDER_ID})"),"paramInsertQuery");
rc = mysql_query(db_connection, lr_eval_string("{paramInsertQuery}"));
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}

// 从数据库读取一个数据并显示
rc = mysql_query(db_connection, "SELECT order_id FROM test_data WHERE status IS FALSE LIMIT 1");
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}
query_result = mysql_use_result(db_connection);
if (query_result == NULL) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_free_result(query_result);
        mysql_close(db_connection);
        lr_abort();
}
// 如果结果集包含多行数据，需要多次调用 mysql_fetch_row 直到返回NULL
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_close(db_connection);
        lr_abort();
}
// 保存参数，用于删除这行数据
lr_save_string(result_row[0], "paramOrderID");
lr_output_message("Order ID is: %s", lr_eval_string("{paramOrderID}"));
mysql_free_result(query_result);

// 在事务里更新一行数据，需要用InnoDB引擎
rc = mysql_query(db_connection, "BEGIN"); //启动事务
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}
// 使用 "FOR UPDATE" 锁住要更新的数据行
rc = mysql_query(db_connection, "SELECT order_id FROM test_data WHERE status IS FALSE LIMIT 1 FOR UPDATE");
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}
query_result = mysql_use_result(db_connection);
if (query_result == NULL) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_free_result(query_result);
        mysql_close(db_connection);
        lr_abort();
}
result_row = (char **)mysql_fetch_row(query_result);
if (result_row == NULL) {
        lr_error_message("没有查询到结果");
        mysql_free_result(query_result);
        mysql_close(db_connection);
        lr_abort();
}
lr_save_string(result_row[0], "paramOrderID");
lr_output_message("Order ID is: %s", lr_eval_string("{paramOrderID}"));
mysql_free_result(query_result);
lr_save_string(lr_eval_string("UPDATE test_data SET status=TRUE, date_used=NOW() WHERE order_id='{paramOrderID}'"),"paramUpdateQuery");
rc = mysql_query(db_connection, lr_eval_string("{paramUpdateQuery}"));
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}
rc = mysql_query(db_connection, "COMMIT"); // 提交事务
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}

// 再次查找数据，应该为空了，因为前面的事务更新了标志
rc = mysql_query(db_connection, "SELECT order_id FROM test_data WHERE status IS FALSE LIMIT 1");
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}
query_result = mysql_use_result(db_connection);
if (query_result == NULL) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_free_result(query_result);
        mysql_close(db_connection);
        lr_abort();
}
result_row = (char **)mysql_fetch_row(query_result);
if (result_row == NULL) {
        lr_output_message("Result set is empty as expected");
        mysql_free_result(query_result);
} else {
        lr_error_message("Did not expect the result set to contain any rows");
        mysql_free_result(query_result);
        mysql_close(db_connection);
        lr_abort();
}

// 删除数据
lr_save_string(lr_eval_string("DELETE FROM test_data WHERE order_id = '{paramOrderID}'"),"paramDeleteQuery");
rc = mysql_query(db_connection, lr_eval_string("{paramDeleteQuery}"));
if (rc != 0) {
        lr_error_message("%s", mysql_error(db_connection));
        mysql_close(db_connection);
        lr_abort();
}

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








====================================分割线================================



最新内容请见作者的GitHub页：http://qaseven.github.io/

文章标签：
云数据库 RDS MySQL 版
关系型数据库
数据库
测试技术
SQL
MySQL
关键词：
SQL数据库
数据库sql
测试性能
数据库测试
SQL性能
相关实践学习
如何在云端创建MySQL数据库
开始实验后，系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
玄学酱
目录
相关文章
jsjsjjs
|
17天前
|
数据采集 监控 机器人
浅谈网页端IM技术及相关测试方法实践（包括WebSocket性能测试）
最开始转转的客服系统体系如IM、工单以及机器人等都是使用第三方的产品。但第三方产品对于转转的业务，以及客服的效率等都产生了诸多限制，所以我们决定自研替换第三方系统。下面主要分享一下网页端IM技术及相关测试方法，我们先从了解IM系统和WebSocket开始。
jsjsjjs
33 4
云深知何处
|
3天前
|
SQL Oracle 数据库
使用访问指导(SQL Access Advisor)优化数据库业务负载
本文介绍了Oracle的SQL访问指导（SQL Access Advisor）的应用场景及其使用方法。访问指导通过分析给定的工作负载，提供索引、物化视图和分区等方面的优化建议，帮助DBA提升数据库性能。具体步骤包括创建访问指导任务、创建工作负载、连接工作负载至访问指导、设置任务参数、运行访问指导、查看和应用优化建议。访问指导不仅针对单条SQL语句，还能综合考虑多条SQL语句的优化效果，为DBA提供全面的决策支持。
云深知何处
23 11
代码掌控者
|
15天前
|
算法 Java 测试技术
Benchmark.NET：让 C# 测试程序性能变得既酷又简单
Benchmark.NET是一款专为 .NET 平台设计的性能基准测试框架，它可以帮助你测量代码的执行时间、内存使用情况等性能指标。它就像是你代码的 "健身教练"，帮助你找到瓶颈，优化性能，让你的应用跑得更快、更稳！希望这个小教程能让你在追求高性能的路上越走越远，享受编程带来的无限乐趣！
代码掌控者
61 13
Apache_Tomcat_Nignx
|
17天前
|
SQL 关系型数据库 MySQL
MySQL导入.sql文件后数据库乱码问题
本文分析了导入.sql文件后数据库备注出现乱码的原因，包括字符集不匹配、备注内容编码问题及MySQL版本或配置问题，并提供了详细的解决步骤，如检查和统一字符集设置、修改客户端连接方式、检查MySQL配置等，确保导入过程顺利。
Apache_Tomcat_Nignx
58 3
运维有小邓
|
16天前
|
SQL 监控 安全
SQL Servers审核提高数据库安全性
SQL Server审核是一种追踪和审查SQL Server上所有活动的机制，旨在检测潜在威胁和漏洞，监控服务器设置的更改。审核日志记录安全问题和数据泄露的详细信息，帮助管理员追踪数据库中的特定活动，确保数据安全和合规性。SQL Server审核分为服务器级和数据库级，涵盖登录、配置变更和数据操作等事件。审核工具如EventLog Analyzer提供实时监控和即时告警，帮助快速响应安全事件。
运维有小邓
34 1
土木林森
|
22天前
|
并行计算 算法 测试技术
C语言因高效灵活被广泛应用于软件开发。本文探讨了优化C语言程序性能的策略，涵盖算法优化、代码结构优化、内存管理优化、编译器优化、数据结构优化、并行计算优化及性能测试与分析七个方面
C语言因高效灵活被广泛应用于软件开发。本文探讨了优化C语言程序性能的策略，涵盖算法优化、代码结构优化、内存管理优化、编译器优化、数据结构优化、并行计算优化及性能测试与分析七个方面，旨在通过综合策略提升程序性能，满足实际需求。
土木林森
51 1
蓝易云
|
28天前
|
缓存 Ubuntu Linux
Linux环境下测试服务器的DDR5内存性能
通过使用 `memtester`和 `sysbench`等工具，可以有效地测试Linux环境下服务器的DDR5内存性能。这些工具不仅可以评估内存的读写速度，还可以检测内存中的潜在问题，帮助确保系统的稳定性和性能。通过合理配置和使用这些工具，系统管理员可以深入了解服务器内存的性能状况，为系统优化提供数据支持。
蓝易云
34 4
那年春天
|
28天前
|
监控 JavaScript 前端开发
如何在实际应用中测试和比较React和Vue的性能？
总之，通过多种方法的综合运用，可以相对客观地比较 React 和 Vue 在实际应用中的性能表现，为项目的选择和优化提供有力的依据。
那年春天
33 1
众所周知
|
1月前
|
数据库连接 Go 数据库
Go语言中的错误注入与防御编程。错误注入通过模拟网络故障、数据库错误等，测试系统稳定性
本文探讨了Go语言中的错误注入与防御编程。错误注入通过模拟网络故障、数据库错误等，测试系统稳定性；防御编程则强调在编码时考虑各种错误情况，确保程序健壮性。文章详细介绍了这两种技术在Go语言中的实现方法及其重要性，旨在提升软件质量和可靠性。
众所周知
29 1
游客ny3yjjsyp7iro
|
26天前
|
SQL Java 数据库连接
canal-starter 监听解析 storeValue 不一样，同样的sql 一个在mybatis执行 一个在数据库操作，导致解析不出正确对象
canal-starter 监听解析 storeValue 不一样，同样的sql 一个在mybatis执行 一个在数据库操作，导致解析不出正确对象
游客ny3yjjsyp7iro
41 0

热门文章

最新文章

  • 1
    运行QTP测试脚本后，将编译结果写入制定文件（三）
  • 2
    命令行及脚本发送邮件测试的方法
  • 3
    [深入JUnit] 测试运行的入口
  • 4
    阿里2015实习生招聘在线测试----编程题，设计有限任务响应队列
  • 5
    linux实时操作系统xenomai x86平台基准测试(benchmark）
  • 6
    prototype中Array的测试
  • 7
    关于dual表的破坏性测试
  • 8
    渗透测试之分享常用工具、插件和脚本（干货）
  • 9
    尝鲜Vue3之四：如何运行Jest单元测试
  • 10
    [20170421]警惕打开IMU对测试的影响.txt
  • 1
    MyBatis基本用法 && 什么是自动化测试 && Spring事务和事务传播机制 && 性能测试概念和术语 && Loadrunner安装
    90
  • 2
    Loadrunner 脚本开发-利用web_submit_data函数实现POST请求
    178
  • 3
    Loadrunner 脚本开发-利用loadrunner开发Windows Sockets协议脚本
    193
  • 4
    Loadrunner 脚本开发-从文件读取数据并参数化
    122
  • 5
    Loadrunner脚本开发-基于HTTP协议的流媒体视频在线播放服务器性能测试
    160
  • 6
    Loadrunner 运行场景-场景中的全局变量与关联结果参数
    132
  • 7
    Loadrunner 脚本开发-利用Loadrunner生成Web service测试脚本
    138
  • 8
    Loadrunner 脚本录制-通过代理录制脚本
    171
  • 9
    Loadrunner 脚本开发-soap_request函数介绍及WebService接口测试
    160
  • 10
    Loadrunner脚本优化-参数化之关联MySQL数据库获取数据
    113

    • 相关课程

    更多
  • 如何在 PolarDB-X 中优化慢 SQL
  • SQL完全自学手册
  • SQL Server on Linux入门教程
  • SQL入门与实践
  • 数据库及SQL/MySQL基础
  • SQL进阶及查询

    • 相关电子书

    更多
  • SQL Server在电子商务中的应用与实践
  • GeoMesa on Spark SQL
  • 原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili

    • 相关实验场景

    更多
  • 使用DAS实现数据库SQL优化
  • PolarDB for AI：在数据库中通过SQL实现AI能力
  • 玩转MaxCompute SQL! 30分钟搞定数据分析挖掘
  • 快速体验PolarDB开源数据库
  • 使用SQL语句实现数据查询操作
  • 使用SQL语句管理索引
    • 下一篇
    DataWorks