package com.ricorsoft.common;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class DBAccess {
private static String driver = "net.sourceforge.jtds.jdbc.Driver";
private static String url = "jdbc:jtds:sqlserver://127.0.0.1:1433/IRC;tds=8.0;lastupdatecount=true;";
private static String username = "sa";
private static String password = "sa";
private Connection conn = null;
public DBAccess()
{
try {
Class.forName(driver);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public Connection getConnection()
{
try {
if (conn == null || conn.isClosed())
conn = DriverManager.getConnection(url,username,password);
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
public void closeConn()
{
try {
if (conn != null)
{
conn.isClosed();
}
} catch (SQLException e) {
// TODO
e.printStackTrace();
}
conn = null;
}
public boolean executeSQL(String sql)
{
boolean isSuccess = false;
Statement stmt = null;
getConnection();
try {
stmt = conn.createStatement();
int result = stmt.executeUpdate(sql);
if (result > 0)
isSuccess = true;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
closeConn();
}
return isSuccess;
}
public ResultSet getResultSet(String sql)
{
Statement stmt = null;
ResultSet rs = null;
getConnection();
try {
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
rs = stmt.executeQuery(sql);
} catch (SQLException e) {
e.printStackTrace();
}finally{
closeConn();
}
return rs;
}
public static void main(String[] args) {
//DBAccess db=new DBAccess();
//System.out.println(db.getConnection());
}
}
评论0