真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

jmeter導(dǎo)入DB數(shù)據(jù)再再優(yōu)化

前言：分享和規(guī)定命名規(guī)范后，各位測(cè)試人員一致認(rèn)為這樣jmeter的jmx文件限制太死，主要體現(xiàn)六方面：

新邵ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場(chǎng)景，ssl證書未來市場(chǎng)廣闊！成為創(chuàng)新互聯(lián)建站的ssl證書銷售渠道，可以享受市場(chǎng)價(jià)格4-6折優(yōu)惠！如果有意向歡迎電話聯(lián)系或者加微信：028-86922220（備注：SSL證書合作）期待與您的合作！

第一：規(guī)定了一個(gè)jmx文件只能錄入一個(gè)接口，這樣會(huì)導(dǎo)致jmx文件很多

第二：導(dǎo)入DB的jmx文件每輪迭代都需要更換版本號(hào)，會(huì)帶來額外的工作

第三：jmx文件嚴(yán)格要求了接口執(zhí)行循序，會(huì)導(dǎo)致大家寫好的用例會(huì)重新輸出

第四：importDB的jmx文件與接口的jmx文件對(duì)應(yīng)也會(huì)很多，不能一個(gè)importDB的jmx完成所有接口的工作

第五：刪除了定義產(chǎn)品類型和頁面類型字段，增加了接口類型字段

第六：測(cè)試反饋終端類型、版本號(hào)、接口類型不需要通過importDB 的jmx文件傳入而是通過http請(qǐng)求名稱按照一定規(guī)則去獲取

因此針對(duì)上面四項(xiàng)不足，做了一些優(yōu)化。

技術(shù)方面方面改變主要體現(xiàn)在：

第一：把終端類型、版本號(hào)、接口類型、接口名稱、用例數(shù)目、用例成功數(shù)目、通過率這些字段，之前只有部分（接口類型、接口名稱）是list結(jié)構(gòu)，現(xiàn)在均改為list結(jié)構(gòu)。
第二：java set操作的sql只有詳細(xì)表，而統(tǒng)計(jì)表是通過sql操作的（通過select詳細(xì)表計(jì)算出來統(tǒng)計(jì)表每個(gè)字段值insert和update的）
第三：聯(lián)合唯一索引增加了一個(gè)字段creatTime，因?yàn)闇y(cè)試反應(yīng)按照之前聯(lián)合索引只能保留本輪迭代的數(shù)據(jù)，有之前的按照迭代保留數(shù)據(jù)，目前是按照當(dāng)天保留數(shù)據(jù)(因此有之前精確到秒改為精確到日)

第四：SQL的各個(gè)字段獲取規(guī)則進(jìn)行了限制

jmeter線程請(qǐng)求命名規(guī)則：
由于代碼做了字段獲取的規(guī)則，循環(huán)到”終端、版本、類型、校驗(yàn)、接口”關(guān)鍵字時(shí)認(rèn)為是本jmx文件需校驗(yàn)的接口和用例

終端類型獲取規(guī)則：

由于代碼做了終端類型獲取的規(guī)則，截取”終端”和“版本”中間的字符作為終端類型

版本號(hào)獲取規(guī)則：

由于代碼做了版本號(hào)獲取的規(guī)則，截取”終端”和“版本”中間的字符作為版本號(hào)

接口類型獲取規(guī)則：
由于代碼做了接口類型獲取的規(guī)則，截取”終端”和“版本”中間的字符作為接口類型

接口名稱獲取規(guī)則：

由于代碼做了接口名稱獲取的規(guī)則，截取”校驗(yàn)”和“接口”中間的字符作為接口名稱

用例名稱獲取規(guī)則：

由于代碼做了用例名稱獲取的規(guī)則，截取”接口”后面的字符作為接口名稱

具體SQL key值的取值方法如下：

jmeter導(dǎo)入DB數(shù)據(jù)再再優(yōu)化

//獲取符合規(guī)則的終端類型
     public static ArrayList  getTerminalType(String path) throws Exception{
             CsvUtil util = new CsvUtil(path);             int rowNum = util.getRowNum();
             String caseAllName = null;
             String TerminalType = null;
             ArrayList terminalTypeArray = new ArrayList();             for(int i=1;i  getVersion(String path) throws Exception{
             CsvUtil util = new CsvUtil(path);             int rowNum = util.getRowNum();
             String caseAllName = null;
             String version = null;
             ArrayList excVersionArray = new ArrayList();             for(int i=1;i  getInterfaceType(String path) throws Exception{
             CsvUtil util = new CsvUtil(path);             int rowNum = util.getRowNum();
             String caseAllName = null;
             String interfaceNameType = null;
             ArrayList interfaceTypeArray = new ArrayList();             for(int i=1;i  getInterfaceName(String path) throws Exception{
         CsvUtil util = new CsvUtil(path);         int rowNum = util.getRowNum();
         String caseAllName = null;
         String interfaceName = null;
         ArrayList interfaceNameArray = new ArrayList();             for(int i=1;i getCaseName(String path) throws Exception{
          CsvUtil util = new CsvUtil(path);         int rowNum = util.getRowNum();
         String caseAllName = null;
         String caseName = null;
         ArrayList caseNameArray = new ArrayList();         for(int i=1;i getcaseIsPass(String path) throws Exception{
        CsvUtil util = new CsvUtil(path);        int rowNum = util.getRowNum();
         ArrayList caseResultArray = new ArrayList();//         System.out.println(CaseNum);
         String caseAllName = null;         for(int i=1;i
jmeter導(dǎo)入DB數(shù)據(jù)再再優(yōu)化
支持和兼容：
第一：支持同個(gè)jmx文件多個(gè)接口用例場(chǎng)景
第二：兼容同個(gè)jmx文件雖同一個(gè)接口不同順序的輸入
一個(gè)要求：
jmeter命名規(guī)則為終端AAA版本BBB類型CCC校驗(yàn)DDD接口EEE
AAA為終端類型（如app、網(wǎng)站） ，BBB為迭代號(hào)（如9.0.1） ，CCC為接口類型（如搜索、跟團(tuán)） ,DDD為接口名稱（如默認(rèn)出發(fā)城市），EEE為用例名稱（如檢驗(yàn)推薦城市否正確）
由于獲取SQL每個(gè)字段均為List，因此若jmeter想使用，必須進(jìn)行二次封裝!!!
jmeter導(dǎo)入DB數(shù)據(jù)再再優(yōu)化
//封裝上面獲取終端類型、版本號(hào)、接口類型、接口名稱、方法提供jmeter使用
     public static ArrayList getTerminalTypeArray(String path) throws Exception{
              ArrayList terminalTypeArray = readCsv.getTerminalType(path);                return terminalTypeArray;
        }     public static ArrayList getVersionArray(String path) throws Exception{
              ArrayList versionTypeArray = readCsv.getVersion(path);                return versionTypeArray;
        }     public static ArrayList getInterfaceTypeArray(String path) throws Exception{
              ArrayList interfaceTypeArray = readCsv.getInterfaceType(path);                return interfaceTypeArray;
        }      public static ArrayList getInterfaceNameArray(String path) throws Exception{
          ArrayList interfaceNameArray = readCsv.getInterfaceName(path);            return interfaceNameArray;
      }      public static ArrayList getCaseNameArray(String path) throws Exception{
              ArrayList caseNameArray = readCsv.getCaseName(path);                return caseNameArray;
          }      public static ArrayList getCaseIsPassArray(String path) throws Exception{
              ArrayList caseIsPassArray = readCsv.getcaseIsPass(path);                return caseIsPassArray;
          }
jmeter導(dǎo)入DB數(shù)據(jù)再再優(yōu)化
好了獲取到了，我們做插入DB操作：
詳細(xì)表跟之前改變不大！！(索引擴(kuò)充一個(gè)createTime字段、時(shí)間有精確到秒改為精確到日)
如：
jmeter導(dǎo)入DB數(shù)據(jù)再再優(yōu)化
 public static String currTime(){
            SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd");//設(shè)置日期格式
            String now = df.format(new Date());// new Date()為獲取當(dāng)前系統(tǒng)時(shí)間
            return now;
        }     //插入詳細(xì)數(shù)據(jù)
     public static boolean insertDetailDB(String terminalType,String excVersion,String interfaceType,String interfaceName,String caseName,String excResult){          try {  
                Class.forName("com.MySQL.jdbc.Driver");  
      
                String databaseName = "test";// 已經(jīng)在MySQL數(shù)據(jù)庫中創(chuàng)建好的數(shù)據(jù)庫。  
                String userName = "mobtest";// MySQL默認(rèn)的root賬戶名  
                String password = "tuniu520";// 默認(rèn)的root賬戶密碼為空  
                String connUrl = "jdbc:mysql://10.10.30.200:3306/";//連接地址
                Connection conn = DriverManager.getConnection(connUrl + databaseName, userName, password);  
                PreparedStatement st = null;
                Statement stmt = conn.createStatement();  
                String createTime = readCsv.currTime();
                String sql = "create table if NOT EXISTS AutoTest_DetailInterface(id int NOT NULL auto_increment primary key ,terminalType varchar(50) NOT  NULL DEFAULT 'App' ,"
                        + "excVersion varchar(50),interfaceType varchar(50) ,interfaceName varchar(50),"
                        + "caseName varchar(50) ,excResult varchar(50),creatTime varchar(50) NOT NULL DEFAULT '"+createTime+"',"
                                + " UNIQUE INDEX  ( terminalType,excVersion,interfaceType,interfaceName,caseName,creatTime ) )";  
//                System.out.println(sql);                // 創(chuàng)建數(shù)據(jù)庫中的表，  
                int result = stmt.executeUpdate(sql);  
                if (result != -1) {  
                    sql = "insert into AutoTest_DetailInterface(terminalType,excVersion,interfaceType,interfaceName,caseName,excResult) values(?,?,?,?,?,?) "
                            + "ON DUPLICATE KEY UPDATE excResult=?";//                    sql = "insert into AutoTest_DetailInterface (permaryTitle,secondaryTitle,excVersion,excTerminal,excResult) 
//                    +values(primaryTitle,secordaryTitle,excVersion,excTerminal,excResult)";
                    st = conn.prepareStatement(sql);                    //存入終端類型轉(zhuǎn)為小寫
                    st.setString(1, terminalType.toLowerCase());
                    st.setString(2, excVersion);
                    st.setString(3, interfaceType);
                    st.setString(4, interfaceName);
                    st.setString(5, caseName);                    //存入執(zhí)行結(jié)果true或者false轉(zhuǎn)為小寫
                    st.setString(6, excResult.toLowerCase());
                    st.setString(7, excResult.toLowerCase());
                    st.executeUpdate();
                    sql = "SELECT * FROM AutoTest_DetailInterface";  
                    System.out.println(stmt.executeQuery(sql));
                    ResultSet rs = stmt.executeQuery(sql);
                    System.out.println("id\tterminalType\texcVersion\tinterfaceType\tinterfaceName\tcaseName\texcResult\tcreatTime"); 
                    while (rs.next()) {  
                         System.out.println(rs.getString(1) + "\t" + rs.getString(2) + "\t" + rs.getString(3) + "\t" + rs.getString(4) + "\t" + rs.getString(5) + "\t" + rs.getString(6) + "\t" + rs.getString(7)+ rs.getString(8));  
                    }  
                }  
                conn.close();  
                  
            } catch (Exception e) {  
                e.printStackTrace();  
                return false;
            }            return true;
     }
jmeter導(dǎo)入DB數(shù)據(jù)再再優(yōu)化
 
插入統(tǒng)計(jì)表：（相比之前思路都改變了~是通過詳細(xì)表select計(jì)算統(tǒng)計(jì)后insert進(jìn)去的而不是通過java依次獲取每個(gè)字段值set進(jìn)去的）
具體如下：
有一點(diǎn)說明：就是SQL在insert的時(shí)候若是insert整個(gè)sql的時(shí)候且當(dāng)唯一聯(lián)合索引鍵相同時(shí)，做更新不能用 key=vaule這種平常的用法（不然拿到第一行的數(shù)據(jù)更新了所有行的數(shù)據(jù)），而是 set key=VALUES(key)
具體用法可以看下http://www.jb51.net/article/39255.htm 這個(gè)用法，備注，因?yàn)檫@點(diǎn)糾結(jié)了我大半天時(shí)間！??！
jmeter導(dǎo)入DB數(shù)據(jù)再再優(yōu)化
//插入統(tǒng)計(jì)數(shù)據(jù)
     public static boolean insertTotalDB(){         try {  
                Class.forName("com.mysql.jdbc.Driver");  
      
                String databaseName = "test";// 已經(jīng)在MySQL數(shù)據(jù)庫中創(chuàng)建好的數(shù)據(jù)庫。  
                String userName = "mobtest";// MySQL默認(rèn)的root賬戶名  
                String password = "tuniu520";// 默認(rèn)的root賬戶密碼為空  
                String connUrl = "jdbc:mysql://10.10.30.200:3306/";//連接地址
                Connection conn = DriverManager.getConnection(connUrl + databaseName, userName, password);  
                PreparedStatement st = null;
                Statement stmt = conn.createStatement(); 
                String createTime = readCsv.currTime();
                String sql = "create table if NOT EXISTS AutoTest_TotalInterface(id int NOT NULL auto_increment primary key ,terminalType varchar(50) NOT  NULL DEFAULT 'App' ,"
                        + "excVersion varchar(50),interfaceType varchar(50) ,interfaceName varchar(50),"
                        + "caseTotalNum int,caseSucNum int,excRate varchar(50) ,creatTime varchar(50) NOT NULL DEFAULT '"+createTime+"',"
                                + " UNIQUE INDEX  ( terminalType,excVersion,interfaceType,interfaceName,creatTime ) )"; 
                // 創(chuàng)建數(shù)據(jù)庫中的表，  
                int result = stmt.executeUpdate(sql);  
                if (result != -1) {  
                    String selectSQL = "SELECT  terminalType,excVersion,interfaceType,"
                            + "interfaceName,caseTotalNum,caseSucNum,"
                            + "ROUND(caseSucNum/caseTotalNum,3) "
                            + "as excRate,creatTime from("
                            + "SELECT terminalType,excVersion,interfaceType,interfaceName,count(1) "
                            + "as caseTotalNum,sum(ex) as caseSucNum,creatTime from("
                            + "SELECT terminalType,excVersion,interfaceType,interfaceName,"
                            + "creatTime,case excResult "
                            + "when 'true' then 1 when 'false' then 0 end as ex from "
                            + "AutoTest_DetailInterface)m group by "
                            + "terminalType,excVersion,interfaceType,interfaceName,creatTime)n";
                     sql = "insert into AutoTest_TotalInterface("
                                + "terminalType,excVersion,interfaceType,interfaceName,caseTotalNum,caseSucNum,"
                                + "excRate,creatTime) "+selectSQL+" ON DUPLICATE KEY UPDATE caseTotalNum=VALUES(caseTotalNum),caseSucNum=VALUES(caseSucNum),excRate=VALUES(excRate)";
                        System.out.println(sql);                        //執(zhí)行插入操作
                        st = conn.prepareStatement(sql);
                        st.executeUpdate();
                        sql = "SELECT * FROM AutoTest_TotalInterface";  
                        System.out.println(stmt.executeQuery(sql));
                     ResultSet rs = stmt.executeQuery(sql);                     while (rs.next()) {  
                         System.out.println(rs.getString(1) + "\t" + rs.getString(2) + "\t" + rs.getString(3) + "\t" + rs.getString(4) + "\t" + rs.getString(5) + "\t" + rs.getString(6) + "\t" + rs.getString(7)+ "\t" + rs.getString(8) + rs.getString(9) );  
                    }  
                }  
                conn.close();  
                  
            } catch (Exception e) {  
                e.printStackTrace();  
                return false;
            }            return true;
    }
jmeter導(dǎo)入DB數(shù)據(jù)再再優(yōu)化
好了，到此結(jié)束，當(dāng)然，importDB的jmx文件也要發(fā)生變化（直接調(diào)用方法即可），具體如下：
jmeter導(dǎo)入DB數(shù)據(jù)再再優(yōu)化
import readDB.*;import excFile.*;


String path = "D:\\excResult.csv";int length = readCsv.getTerminalTypeArray(path).size();
log.info("用例數(shù)量為："+length);//循環(huán)獲取各個(gè)參數(shù)for(int i=0;i
jmeter導(dǎo)入DB數(shù)據(jù)再再優(yōu)化
導(dǎo)入DB數(shù)據(jù)如下:
原始數(shù)據(jù)：
導(dǎo)入詳細(xì)表的數(shù)據(jù)：
導(dǎo)入統(tǒng)計(jì)表數(shù)據(jù)：
            
            
                        

            文章標(biāo)題：jmeter導(dǎo)入DB數(shù)據(jù)再再優(yōu)化            

            新聞來源：http://weahome.cn/article/gddjgg.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220（工作日）

18980820575（7×24）

提交需求

返回頂部