package com.product.data.sync.util;
|
|
import com.product.core.config.Global;
|
import com.product.core.exception.BaseException;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.boot.context.properties.ConfigurationProperties;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.context.annotation.PropertySource;
|
import org.springframework.stereotype.Component;
|
|
import java.sql.Connection;
|
import java.sql.DriverManager;
|
import java.sql.SQLException;
|
|
/**
|
* @Author cheng
|
* @Date 2022/1/18 15:09
|
* @Desc 获取当前数据库连接
|
*/
|
public class ConnectionManager {
|
private static ConnectionManager connectionManager = new ConnectionManager();
|
|
private String url;
|
|
private String userName;
|
|
private String password;
|
|
private String driver;
|
|
private String databaseType;
|
|
public ConnectionManager() {
|
System.out.println(this);
|
this.url = Global.getSystemConfig("data.source.url", "");
|
this.userName = Global.getSystemConfig("data.source.user", "");
|
this.password = Global.getSystemConfig("data.source.password", "");
|
this.driver = Global.getSystemConfig("data.source.driver", "");
|
this.databaseType = Global.getSystemConfig("data.source.type", "");
|
}
|
|
/**
|
* 获取jdbc连接
|
*
|
* @param diver jdbc连接类型
|
* @param jdbc 连接url
|
* @param user 用户名
|
* @param pwd 密码
|
* @return JDBC连接
|
* @throws BaseException
|
*/
|
public static Connection getConnection(String diver, String jdbc, String user, String pwd) throws BaseException {
|
try {
|
Class.forName(diver);
|
Connection connection = DriverManager.getConnection(jdbc, user, pwd);
|
return connection;
|
} catch (Exception e) {
|
SpringMVCContextHolder.getSystemLogger().error(e);
|
throw new BaseException(e);
|
}
|
}
|
|
/**
|
* 获取数据库连接
|
*
|
* @return
|
* @throws BaseException
|
*/
|
public final static Connection getConnection() throws BaseException {
|
try {
|
Class.forName(connectionManager.driver);
|
return DriverManager.getConnection(connectionManager.url, connectionManager.userName, connectionManager.password);
|
} catch (SQLException | ClassNotFoundException e) {
|
throw new BaseException(e);
|
}
|
}
|
|
|
}
|
