数据库连接：
package com.sz.lgyw.util;
import java.sql.ResultSet;
import java.sql.PreparedStatement;
import java.sql.Statement;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
//import javax.naming.NamingException;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.commons.dbcp.BasicDataSource;
import com.sz.xml.DatabaseXmlConfig;
//import com.sz.lgyw.ejb.util.ContextFactory;
public class DataSourceConn {
public BasicDataSource ds = null;
//public DataSource ds;
protected PreparedStatement psmt;
protected Connection conn;
protected ResultSet rs;
private static Log log = LogFactory.getLog(DataSourceConn.class);
protected DatabaseXmlConfig dg;
protected Statement stmt ;
public DataSourceConn() {
//ContextFactory f = ContextFactory.getInstance();
//ds = (DataSource) f.getInitialContext().lookup("java:/OracleDS");
//ds = (DataSource) f.getInitialContext().lookup("java:/env/jdbc/OracleDS");
ds = new BasicDataSource();
dg = new DatabaseXmlConfig();
ds.setDefaultAutoCommit(true);
ds.setDriverClassName(dg.getDriverClassName());
ds.setUrl(dg.getUrl());
ds.setUsername(dg.getUserName());
ds.setPassword(dg.getPassword());
try {
conn = ds.getConnection();
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_UPDATABLE);
}
catch (SQLException sqle) {
log.info("getConnection Err: " + sqle.getMessage());
System.out.println("getConnection Err: " + sqle.getMessage());
}
}
public Connection getConnection() {
return conn;
}
public PreparedStatement getPrepareStatement(String sql) {
try {
psmt = conn.prepareStatement(sql);
}
catch (SQLException ex) {
ex.printStackTrace();
log.info("prepareStatement: " + ex.getMessage() + " SQL:" + sql);
}
return psmt;
}
public ResultSet executeQuery(String sql) {
try {
rs = stmt.executeQuery(sql);
}
catch (SQLException ex) {
log.info("executeQuery: " + ex.getMessage() + " SQL:" + sql);
}
return rs;
}
public int executeUpdate(String sql) {
int r = 0;
try {
r = stmt.executeUpdate(sql);
}
catch (SQLException ex) {
log.info("executeQuery: " + ex.getMessage() + " SQL:" + sql);
}
return r;
}
public static void main(String[] args) {
String test_sql = "select * from t_user";
DataSourceConn ds = new DataSourceConn();
ResultSet rs = ds.executeQuery(test_sql);
try {
rs.last();
System.out.println(rs.getRow());
}
catch (SQLException sqlE) {
System.out.println("main :" + sqlE.getMessage());
}
}
}
[返回] 计算机科学论坛 →
XML.ORG.CN讨论区 - XML技术 → 『 XML源码及示例(仅原创和转载) 』 → jdom samples (4)
(订阅本版)
2004/4/7 15:10:00
新浪微博
jdom samples (4)
