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;

}

}