59 lines
1.7 KiB
Java
59 lines
1.7 KiB
Java
package com.muyu.auth.service;
|
|
|
|
import com.muyu.auth.form.Firm;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.data.redis.core.RedisTemplate;
|
|
|
|
|
|
import java.sql.Connection;
|
|
import java.sql.DriverManager;
|
|
import java.sql.ResultSet;
|
|
import java.sql.Statement;
|
|
|
|
/**
|
|
* 数据源
|
|
* @author 袁子龙
|
|
* @package com.muyu.auth.service
|
|
* @name SysFirmService
|
|
* @date 2024/9/30 11:05
|
|
*/
|
|
@Component
|
|
public class SysFirmService {
|
|
|
|
//数据库账号
|
|
static final String USER="root";
|
|
//数据库密码
|
|
static final String PASSWORD="Lw030106";
|
|
|
|
@Autowired
|
|
private RedisTemplate redisTemplate;
|
|
public Firm findFirmByName(String firmName){
|
|
Firm firm = new Firm();
|
|
try {
|
|
DriverManager.registerDriver(new com.mysql.cj.jdbc.Driver());
|
|
Connection connection= DriverManager.getConnection("jdbc:mysql://47.101.53.251:3306/datasource?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT&useSSL=false",USER,PASSWORD);
|
|
String sql="select * from `datasource` where firm_name = '"+firmName+"'";
|
|
|
|
Statement stmt = connection.createStatement();
|
|
ResultSet rs = stmt.executeQuery(sql);
|
|
|
|
|
|
while (rs.next()){
|
|
firm.setId(rs.getInt("id"));
|
|
firm.setFirmName(rs.getString("firm_name"));
|
|
firm.setDatabaseName(rs.getString("database_name"));
|
|
}
|
|
|
|
} catch (Exception e) {
|
|
throw new RuntimeException(e);
|
|
}
|
|
|
|
//数据源不为空
|
|
if (firm!=null){
|
|
redisTemplate.opsForValue().set("datasource",firm.getDatabaseName());
|
|
}
|
|
return firm;
|
|
};
|
|
}
|