?? dbpool.java
字號(hào):
package dbcp;
import org.apache.commons.dbcp.BasicDataSource;
import org.apache.commons.dbcp.BasicDataSourceFactory;
import java.io.UnsupportedEncodingException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.Statement;
import java.util.Properties;
public class DBPool {
private static BasicDataSource dataSource = null;
public DBPool() {
}
public static void init() {
String dbIp="127.0.0.1"; //數(shù)據(jù)庫Ip
String dbPort="3306"; //數(shù)據(jù)庫端口
String dbName="chatdb"; //數(shù)據(jù)庫名字
String dbUserName="root";
String dbPassWord="rootroot";
if (dataSource != null) {
try {
dataSource.close();
} catch (Exception e) {
//
}
dataSource = null;
}
try {
Properties p = new Properties();
p.setProperty("driverClassName", "com.mysql.jdbc.Driver");
p.setProperty("url", "jdbc:mysql://"+dbIp+":"+dbPort+"/"+dbName);
p.setProperty("password", dbPassWord);
p.setProperty("username", dbUserName);
p.setProperty("initialSize", "10");
p.setProperty("maxActive", "30");
p.setProperty("maxIdle", "10");
p.setProperty("maxWait", "1000");
p.setProperty("removeAbandoned", "false");
p.setProperty("removeAbandonedTimeout", "120");
p.setProperty("testOnBorrow", "true");
p.setProperty("logAbandoned", "true");
dataSource = (BasicDataSource) BasicDataSourceFactory.createDataSource(p);
} catch (Exception e) {
//
}
}
public static synchronized Connection getConnection() throws SQLException {
if (dataSource == null) {
init();
}
Connection conn = null;
if (dataSource != null) {
conn = dataSource.getConnection();
}
return conn;
}
public static void main(String[] args) {
Connection conn = null;
DBPool dbpool=new DBPool();
Statement stmt = null;
dbpool.init();
try {
conn=dbpool.getConnection();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
try {
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
} catch (SQLException e) {
// TODO Auto-generated catch block
}
String sql="insert into t_user values(1,'cwj','aaa',3)";
try {
stmt.execute(sql);
} catch (SQLException e) {
// TODO Auto-generated catch block
}
try {
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -