JavaBean之封装Jdbc操做

package com.gogofun.javabean;

import java.sql.*;

public class DB {

private static boolean isInit = false;

private static String mysqlDriver = "com.mysql.jdbc.Driver";

private static String oracleDriver = "oracle.jdbc.driver.OracleDriver";

private static String mysqlConn = "jdbc:mysql://";

private static String oracleConn = "jdbc:oracle:this:@";

private static PreparedStatement pstmt = null;

private static void init() {

try {

Class.forName(mysqlDriver);

Class.forName(oracleDriver);

isInit = true;

} catch (ClassNotFoundException e) {

e.printStackTrace();

isInit = false;

}

}

//外部获取Mysql驱动字符串

public static String getMysqlDriver() {

   return mysqlDriver;

}

//外部获取Oracle驱动字符串

public static String getOracleDriver() {

   return oracleDriver;

}

//该方法链接本地服务器,默认端口

public static Connection getMysqlConnection(String dbName,

String dbUser, String dbPassword) {

if (!isInit) {

init();

}

String connStr = mysqlConn + "localhost/" + dbName + "?user=" + dbUser

+ "&password=" + dbPassword;

try {

return DriverManager.getConnection(connStr);

} catch (SQLException e) {

e.printStackTrace();

return null;

}

}

//该方法链接指定IP服务器，默认端口

public static Connection getMysqlConnection(String dbIp, String dbName,

String dbUser, String dbPassword) {

if (!isInit) {

init();

}

String connStr = mysqlConn + dbIp + "/" + dbName + "?user=" + dbUser

+ "&password=" + dbPassword;

try {

return DriverManager.getConnection(connStr);

} catch (SQLException e) {

e.printStackTrace();

return null;

}

}

//该方法链接本地服务器,默认端口

public static Connection getOracleConnection(String dbName,

String dbUser, String dbPassword) {

if (!isInit) {

init();

}

String connStr = oracleConn + "localhost:1521:" + dbName;

try {

return DriverManager.getConnection(connStr,dbUser,dbPassword);

} catch (SQLException e) {

e.printStackTrace();

return null;

}

}

//该方法链接本地服务器，指定端口

/*

public static Connection getOracleConnection(String dbPort,String dbName,

String dbUser, String dbPassword) {

if (!isInit) {

init();

}

   String connStr = oracleConn +"localhost:" + dbPort +":" + dbName;

try {

return DriverManager.getConnection(connStr,dbUser,dbPassword);

} catch (SQLException e) {

e.printStackTrace();

return null;

}

}*/

//该方法链接指定IP服务器，默认端口

public static Connection getOracleConnection(String dbIp,String dbName,

String dbUser, String dbPassword) {

if (!isInit) {

init();

}

   String connStr = oracleConn + dbIp + ":1521:" + dbName;

try {

return DriverManager.getConnection(connStr,dbUser,dbPassword);

} catch (SQLException e) {

e.printStackTrace();

return null;

}

}

//该方法链接指定IP服务器，指定端口

public static Connection getOracleConnection(String dbIp,String dbPort,String dbName,

String dbUser, String dbPassword) {

if (!isInit) {

init();

}

String connStr = oracleConn + dbIp + ":" + dbPort +":" + dbName;

try {

return DriverManager.getConnection(connStr,dbUser,dbPassword);

} catch (SQLException e) {

e.printStackTrace();

return null;

}

}

//执行一条SQL Query语句

public static ResultSet executeQuery(Connection conn,String sqlQ) {

if((conn == null)|| (sqlQ == null)) {

return null;

}

try {

pstmt = conn.prepareStatement(sqlQ);

return pstmt.executeQuery();

} catch (SQLException e) {

e.printStackTrace();

close(pstmt);

return null;

}

}

//执行一条SQL Update语句

public static boolean executeUpdate(Connection conn,String sqlU) {

if((conn == null)|| (sqlU == null)) {

return false;

}

try {

pstmt = conn.prepareStatement(sqlU);

pstmt.executeUpdate();

return true;

} catch (SQLException e) {

e.printStackTrace();

close(pstmt);

return false;

}

}

//关闭链接

public static boolean close (Connection conn) {

try {

if(conn != null) {

conn.close();

conn = null;

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

return false;

}

return true;

}

//关闭语句

public static boolean close (Statement stmt) {

try {

if(stmt != null) {

stmt.close();

stmt = null;

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

return false;

}

return true;

}

//关闭结果集

public static boolean close (ResultSet rs) {

try {

if(rs != null) {

rs.close();

rs = null;

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

return false;

}

return true;

}

}