您的位置:首页 > 数据库

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

2013-05-30 14:17 423 查看
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();
}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: 
相关文章推荐