共同的连接工具类
package com.hipad.util;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
/**
* @author: create by libin
* @version: v1.0
* @description: com.hipad.util
* @date:2018年5月2日
*/
public class MyJdbcUtils {
private static String driverName;
private static String url;
private static String user;
private static String password;
private static ThreadLocal<Connection> local = new ThreadLocal<>();
private static String loginUri;
private MyJdbcUtils() {
}
static {
try {
Properties prop = new Properties();
InputStream in = MyJdbcUtils.class.getResourceAsStream("/jdbc.properties");
prop.load(in);
driverName = prop.getProperty("DriverName");
url = prop.getProperty("url");
user = prop.getProperty("user");
password = prop.getProperty("password");
loginUri = prop.getProperty("loginUri");
Class.forName(driverName);
} catch (Exception e) {
e.printStackTrace();
}
}
public static String getLoginUri() {
return loginUri;
}
/**
* 获取连接的方式
*
* @return
* @throws SQLException
*/
public static Connection getConnection() throws Exception {
Connection conn = local.get();
if (conn == null) {
conn = DriverManager.getConnection(url, user, password);
local.set(conn);
}
return conn;
}
/**
* 提交事务的方法
*
* @throws Exception
*/
public static void commit() throws Exception {
getConnection().commit();
}
/**
* 回滚事务
*
* @throws Exception
*/
public static void rollback() throws Exception {
getConnection().rollback();
}
/**
* 开启事务
*
* @throws Exception
*/
public static void startTransaction() throws Exception {
getConnection().setAutoCommit(false);
}
// 针对查询释放资源
public static void release(ResultSet rs, Statement stmt, Connection conn) {
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
rs = null;
}
if (stmt != null) {
try {
stmt.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
stmt = null;
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
conn = null;
}
}
// 针对增删改释放资源
public static void release(Statement stmt, Connection conn) {
if (stmt != null) {
try {
stmt.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
stmt = null;
}
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
conn = null;
}
}
}
1,jdbc连接oracle
连接所需:ojdbc14.jar,jdbc.properties配置文件,共同的连接工具类
jdbc.properties
DriverName=oracle.jdbc.driver.OracleDriver
url=jdbc:oracle:thin:@10.1.6.58:1521:orcl
user=用户名
password=密码
2,jdbc连接mysql
连接所需:mysql-connector-java-5.1.39-bin.jar,jdbc.properties配置文件,共同的连接工具类
DriverName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/hipad_sl
user=root
password=123
3,jdbc连接sqlserver
连接所需:sqljdbc42.jar,jdbc.properties配置文件,共同的连接工具类
jdbc.properties
DriverName=com.microsoft.sqlserver.jdbc.SQLServerDriver
url=jdbc:sqlserver://10.1.6.24:1433;DatabaseName=AIS20180518162016
user=user
password=password