dataProvider数据获取存储数据库
作者：互联网
实体报告类
CREATE TABLE `testngreport_two` (
`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '编号',
`uuid` varchar(100) NOT NULL COMMENT '编号',
`passed` varchar(255) DEFAULT NULL COMMENT '通过',
`failed` varchar(255) DEFAULT NULL COMMENT '失败',
`skipped` varchar(255) DEFAULT NULL COMMENT '跳过',
`duration` varchar(255) DEFAULT NULL COMMENT '使用时间',
`test_user` varchar(255) DEFAULT NULL COMMENT '测试用户人员',
`systemInfo` varchar(255) DEFAULT NULL COMMENT '系统信息',
`test_time` datetime DEFAULT NULL COMMENT '测试时间',
`description` varchar(255) DEFAULT NULL COMMENT '用例描述',
`starttime` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '开始时间',
`endtime` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '结束时间',
`Interfacename` varchar(255) DEFAULT NULL COMMENT '接口名字',
`type` varchar(255) DEFAULT NULL COMMENT '类型',
`failuredetails` varchar(500) DEFAULT NULL COMMENT '失败详情',
`testPackageNamePath` varchar(255) DEFAULT NULL COMMENT '包名方类名方法名',
`requestUrl` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '请求url',
`requestBody` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '请求body',
`requestParameter` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '请求参数',
`responseBody` longtext CHARACTER SET utf8 COLLATE utf8_general_ci COMMENT '响应信息',
PRIMARY KEY (`id`,`uuid`)
) ENGINE=InnoDB AUTO_INCREMENT=380 DEFAULT CHARSET=utf8;
实体请求类
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;
import lombok.extern.log4j.Log4j;
import java.util.Map;
/**
* @author liwen406
* @Title: MyHttpEntity
* @Description: 请求实体类
* @date 2019/3/24 / 17:54
*/
@Log4j
@Data
@NoArgsConstructor
@AllArgsConstructor
@Accessors(chain = true)
public class MyHttpEntity implements Entity {
String url;
String ip;
String body;
String info;
Map<String, ?> parameter;
Map<String, String> header;
}
数据配置链接
import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
/**
* @author liwen406
* @Title: JDBCUtils
* @Description: 1. 声明静态数据源成员变量
* 2. 创建连接池对象
* 3. 定义公有的得到数据源的方法
* 4. 定义得到连接对象的方法
* 5. 定义关闭资源的方法
* @date 2019/3/20 / 13:34
*/
public class JDBCUtils {
/**1. 声明静态数据源成员变量*/
private static DataSource ds;
/**2. 创建连接池对象*/
static {
/**加载配置文件中的数据*/
InputStream is = JDBCUtils.class.getClassLoader().getResourceAsStream("application.yml");
Properties pp = new Properties();
try {
pp.load(is);
/** 创建连接池，使用配置文件中的参数*/
ds = DruidDataSourceFactory.createDataSource(pp);
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 3. 定义公有的得到数据源的方法
* @return
*/
public static DataSource getDataSource() {
return ds;
}
/**
* 4. 定义得到连接对象的方法
* @return
* @throws SQLException
*/
public static Connection getConnection() throws SQLException {
return ds.getConnection();
}
/**
* 5.定义关闭资源的方法
* @param conn
* @param stmt
* @param rs
*/
public static void close(Connection conn, Statement stmt, ResultSet rs) {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
}
}
if (stmt != null) {
try {
stmt.close();
} catch (SQLException e) {
}
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
}
}
}
/***
* 6.重载关闭方法
* @param conn
* @param stmt
*/
public static void close(Connection conn, Statement stmt) {
close(conn, stmt, null);
}
}
数据库sql写法
private JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
public int savereportTwo1(TestngReport testngReport) {
testngReport.setUuid(Tool.getUUID());
testngReport.setTesttime(new Date());
int id = 0;
try {
//1.定义sql
String sql = "INSERT INTO testngreport_two(uuid,duration,test_user," +
"test_time,starttime,endtime," +
"requestUrl,requestBody,requestParameter,responseBody) VALUES (?,?,?,?,?,?,?,?,?,?)";
//2.执行sql
id = template.update(sql, testngReport.getUuid(),
testngReport.getDuration(),
testngReport.getTestuser(),
testngReport.getTesttime(),
testngReport.getStarttime(),
testngReport.getEndtime(),
testngReport.getRequestUrl(),
testngReport.getRequestBody(),
testngReport.getRequestParameter(),
testngReport.getResponseBody()
);
log.info("插入成功：" + id);
} catch (DataAccessException e) {
log.info("插入失败");
e.printStackTrace();
}
return id;
}
test类
@DataProvider
public Object[][] getparam() {
int k = 0;
String[] param = {"2367952", "2367141", "2366552", "2364334"};
Object[][] result = new Object[param.length][];
for (int i = 0; i < param.length; i++) {
MyHttpEntity httpEntity = new MyHttpEntity();
httpEntity.setUrl("https://blog.51cto.com/357712148/" + param[i]);
result[k++] = new Object[]{httpEntity};
}
return result;
}
@Test(dataProvider = "getparam", dataProviderClass = Dataprovidert.class)
public void mydatep(MyHttpEntity httpEntity) {
TestngReportRaoimpl reportRaoimpl = new TestngReportRaoimpl();
Long starttime = System.currentTimeMillis();
HttpResponse response = HttpRequest.get(httpEntity.url).execute();
Assert.assertTrue(response.body().contains("success"));
Long endttime = System.currentTimeMillis();
TestngReport testngReport = new TestngReport();
testngReport.setRequestUrl(httpEntity.getUrl());
testngReport.setStarttime(starttime + "");
testngReport.setEndtime(endttime + "");
testngReport.setTestuser("liwen");
testngReport.setRequestParameter(httpEntity.getParameter() + "");
testngReport.setResponseBody(response.body());
testngReport.setRequestBody(httpEntity.getBody());
testngReport.setDuration((endttime - starttime) + "毫秒");
reportRaoimpl.savereportTwo1(testngReport);
}
结果：
标签：COMMENT,存储,testngReport,varchar,DEFAULT,数据库,NULL,import,dataProvider 来源： https://blog.51cto.com/357712148/2368312