jdbc 连接各种数据库

时间:2023-03-09 09:48:37
jdbc 连接各种数据库
 package com.fh.controller.ruitai.util;

 import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement; //连接瑞泰餐饮前台数据库
public class DBConnectSS { private static String dbURL = "192.168.186.128";
private static String databaseName = "ssycyv8";
private static String dbUser = "sa";
private static String dbPassword = "88888888"; public static Connection getConnectionForSS() {
Connection conn = null;
try {
String url = "jdbc:sqlserver://" + dbURL + ";databaseName="
+ databaseName + ";user=" + dbUser + ";password="
+ dbPassword;// sa身份连接
// Establish the connection.
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
conn = DriverManager.getConnection(url, dbUser, dbPassword);
} catch (ClassNotFoundException | SQLException e) {
e.printStackTrace();
}
return conn;
} public static Connection getConnectionForSS(String dbURL,String databaseName,String dbUser,String dbPassword) {
Connection conn = null;
try { String url = "jdbc:sqlserver://" + dbURL + ";databaseName="
+ databaseName + ";user=" + dbUser + ";password="
+ dbPassword;// sa身份连接
// Establish the connection.
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
conn = DriverManager.getConnection(url, dbUser, dbPassword);
} catch (ClassNotFoundException | SQLException e) {
e.printStackTrace();
}
return conn;
} /**
* @param dbtype 数据库类型
* @param username 用户名
* @param password 密码
* @param dburl 数据库连接地址:端口
* @param databaseName 数据库名
* @return
* @throws SQLException
* @throws ClassNotFoundException
*/
public static Connection getCon(String dbtype,String username,String password,String dburl,String databaseName) throws SQLException, ClassNotFoundException{
System.out.print("数据库连接地址:"+"jdbc:sqlserver://"+dburl+"; DatabaseName="+databaseName+username+ password);
if("mysql".equals(dbtype)){
Class.forName("com.mysql.jdbc.Driver");
return DriverManager.getConnection("jdbc:mysql://"+dburl+"/"+databaseName+"?user="+username+"&password="+password);
}else if("oracle".equals(dbtype)){
Class.forName("oracle.jdbc.driver.OracleDriver");
return DriverManager.getConnection("jdbc:oracle:thin:@"+dburl+":"+databaseName, username, password);
}else if("sqlserver".equals(dbtype)){
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
return DriverManager.getConnection("jdbc:sqlserver://"+dburl+"; DatabaseName="+databaseName, username, password);
}else{
return null;
}
} /**
* @description 关闭数据库的所有连接
* @param con
* @param stmt
* @param rs
*/
public static void closeAll(Connection con, Statement stmt, ResultSet rs) {
if (rs != null)
try {
rs.close();
} catch (Exception e) {
}
if (stmt != null)
try {
stmt.close();
} catch (Exception e) {
}
if (con != null)
try {
con.close();
} catch (Exception e) {
}
} // 测试
public static void main(String[] args) {
// Declare the JDBC objects.
Connection con = null;
Statement stmt = null;
ResultSet rs = null;
try {
con = getConnectionForSS();
String SQL = SqlConst.getOders("",null);
System.out.println(SQL);
stmt = con.createStatement();
rs = stmt.executeQuery(SQL);
int i = 1;
while (rs.next()) {
i = i + 1;
System.out.println("个数:" + i);
System.out.println(rs.getString(1) + " " + rs.getString(2));
} } catch (Exception e) {
e.printStackTrace();
} finally {
closeAll(con, stmt, rs);
}
} public static String getDbURL() {
return dbURL;
} public static void setDbURL(String dbURL) {
DBConnectSS.dbURL = dbURL;
} public static String getDatabaseName() {
return databaseName;
} public static void setDatabaseName(String databaseName) {
DBConnectSS.databaseName = databaseName;
} public static String getDbUser() {
return dbUser;
} public static void setDbUser(String dbUser) {
DBConnectSS.dbUser = dbUser;
} public static String getDbPassword() {
return dbPassword;
} public static void setDbPassword(String dbPassword) {
DBConnectSS.dbPassword = dbPassword;
} }