import lrapi.lr;
import java.util.ArrayList;
import java.util.List;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class Actions

{
private List merchant=new ArrayList<String>();
private List org_id=new ArrayList<String>();
private List receipt_type=new ArrayList<String>();
private Connection conn=null;

private Statement stmt=null;

private ResultSet rs=null;
private String merchantid="";
private String server="";//資料庫地址

private String dataBase="";//資料庫名

private String username="";//使用者名稱

private String passworkd="";//密碼

public int init() throws Throwable{

Class.forName("com.mysql.jdbc.Driver").newInstance();
String url = "jdbc:mysql://192.168.*.*:3320/ocean"; //mysql連線地址
String user = "coral";
String password = "pwd";
Class.forName ("com.mysql.jdbc.Driver");
conn = (Connection) DriverManager.getConnection ( url, user, password );

stmt=conn.createStatement();

return 0;

}

public int action() throws Throwable

{
merchantid=lr.eval_string("{IP}");
lr.start_transaction("aaaa");
rs=stmt.executeQuery("select t.product_name_id from t_coral_rakeback t where t.receipt_type='<receipt_type>' and t.org_id=<IP> and t.biz_type=<biz>");

while(rs.next()&& !"".equals(rs.getString("product_name_id")))

{
lr.error_message("org"+lr.eval_string("<IP>"));
lr.error_message("product_name_id"+rs.getString("product_name_id")); //打印出查詢的結果
//lr.error_message("receipt_type"+rs.getString("receipt_type"));
merchant.add(merchantid); //
org_id.add(lr.eval_string("<IP>"));
receipt_type.add(rs.getString("product_name_id"));

}
lr.end_transaction("aaaa", lr.PASS);
return 0;

}

public int end() throws Throwable{
System.out.println("end=====merchant=============");
for (Object object : merchant) {
lr.error_message((String)object);
}
lr.error_message("org_id============");
for (Object object1 : org_id) {
lr.error_message((String)object1);
}
lr.error_message("product_name_id============");
for (Object object2 : receipt_type) {
lr.error_message((String)object2);
}
stmt.close();

conn.close();

return 0;

}

}

本文來自部落格園，作者：up~up，轉載請註明原文連結：https://www.cnblogs.com/soft-engineer/p/15009631.html