oracle和Mysql连接数据库

b4044v2443

　　Mysql方式：
　　
　　import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
　　public class MysqlDB {
private String strClass = "com.mysql.jdbc.Driver";
private String strDriver = "jdbc:mysql://localhost:3306/s_smdb";
private String strUser = "root";
private String strPwd = "123";
private Connection conn = null;
private Statement stmt = null;
private ResultSet rs = null;
private static CDBAccess instance = null;

private CDBAccess() throws ClassNotFoundException, SQLException{
Class.forName(strClass);
conn = DriverManager.getConnection(strDriver,strUser,strPwd) ;
}

public static CDBAccess getInstance() throws ClassNotFoundException, SQLException{
if(instance == null){
instance = new CDBAccess();
}

return instance;
}

public ResultSet executeQuery(String strsql) throws SQLException{
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
rs = stmt.executeQuery(strsql);

return rs;
}

public int executeUpdate(String strsql) throws SQLException{
int i = 0;
stmt = conn.createStatement();
i = stmt.executeUpdate(strsql);

return i;
}


public void close() throws SQLException{
if(rs != null){
rs.close();
}
if(stmt != null){
stmt.close();
}
if(conn != null){
conn.close();
}
if(instance != null){
instance = null;
}
}
}
　　
　　Oracle方式：
　　package util;
　　import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
　　public class OracleDB {
public static Connection getConnection(){
Connection con=null;
String driver="oracle.jdbc.driver.OracleDriver";
String url="jdbc:oracle:thin:@192.168.8.34:1521:ora9";
String username="scott";
String password="tiger";
try{
Class.forName(driver);

con=DriverManager.getConnection(url,username,password);
}catch(Exception e){
e.printStackTrace();
}
return con;
}
public ResultSet exeQuery(String sql){
ResultSet rs=null;
Connection con=null;
Statement sta=null;

try{
con=getConnection();
sta = con.createStatement();
rs=sta.executeQuery(sql);
}catch(Exception e){
e.printStackTrace();
}
return rs;
}

public int upaQuery(String sql){

Connection con=null;
int i=0;
try{
con=getConnection();
con.setAutoCommit(false);
Statement sta = con.createStatement();
i=sta.executeUpdate(sql);
con.commit();
}catch(Exception e){
e.printStackTrace();
}
return i;
}
//3.关闭资源
public static void release(ResultSet rs,Statement stamt,Connection con){
if(rs!=null){
try{
rs.close();
}catch(Exception e){
e.printStackTrace();
}
}
if(stamt!=null){
try{
stamt.close();
}catch(Exception e){
e.printStackTrace();
}
}
if(con!=null){
try{
con.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
}