加载db2的驱动类，连接数据库URL下的特定schema并插入数据

secce

package com.ssss.gggg.test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class CreatOfRoster {
// get chat db properties from openfire global property API
public static final String DB_CONNECT_URL = "jdbc:db2://10.23.250.41:50000/isse2:currentSchema=cssde;";
public static final String DB_USER = "root2";
public static final String DB_PASSWORD = "root2";
// 创建好友关系ROSTER的sql
private static final String CREATE_ROSTER = "INSERT INTO OFROSTER (ROSTERID, USERNAME, JID, SUB, ASK, RECV, NICK) VALUES (?, ?, ?, 3, -1, -1, ?)";
private static final String CLUSTER = "@cluster.ee.com";
public static final int TOTAL_TEST_NUM = 10;
// 负载均衡服务器端口
public static final int PORT_NUM = 15222;
// 创建好友关系ROSTER的sql
private static final String PAN_USER = "panuser";
static Connection getConnection() throws ClassNotFoundException, SQLException {
// 加载db2的驱动类
Class.forName("com.ibm.db2.jcc.DB2Driver");
Connection conn = DriverManager.getConnection(DB_CONNECT_URL, DB_USER, DB_PASSWORD);
return conn;
}
public static void creatRosterImpl(int rosterId, String username, String cluster, String nick)
throws SQLException, ClassNotFoundException {
Connection con = null;
PreparedStatement pstmt = null;
con = getConnection();
pstmt = con.prepareStatement(CREATE_ROSTER);
pstmt.setInt(1, rosterId);
pstmt.setString(2, username);
pstmt.setString(3, cluster);
pstmt.setString(4, nick);
pstmt.executeUpdate();
}
}