package com.battery.device.neware;
|
|
import java.nio.file.Path;
|
import java.util.List;
|
import java.util.Locale;
|
import java.util.Map;
|
import com.battery.device.api.DeviceAdapter;
|
import com.battery.device.api.DeviceAdapterException;
|
import com.battery.device.api.credentials.LocalCredentials;
|
import com.battery.device.api.model.AdapterCapabilities;
|
import com.battery.device.api.registry.AdapterInstanceConfig;
|
import com.battery.device.api.registry.DeviceAdapterFactory;
|
|
/**
|
* 按存储形态 {@code NEWARE_MYSQL} 构造直连厂商库的只读适配器实例。
|
*
|
* <p>连接口令不进数据库、不进仓库，也不打包进 jar，取值顺序见 {@link #credential}：
|
* 本地凭据文件 → 同名环境变量 → 同名 JVM 启动参数。三者都没有时装配失败，
|
* 错误信息同时点名文件路径与变量名，使"忘了放口令"是可见的失败而不是沉默的缺失。
|
* 账号固定为现场取得的服务端只读账号，全权限账号不进入配置。
|
*/
|
public final class NewareMysqlAdapterFactory implements DeviceAdapterFactory
|
{
|
public static final String DATABASE_OPTION = "database";
|
public static final String USER_OPTION = "user";
|
public static final String PASSWORD_ENV_OPTION = "passwordEnv";
|
private static final String DEFAULT_DATABASE = "bts63";
|
private static final String READ_ONLY_USER = "visitor";
|
/** 现场已知的全权限账号；写进交付配置就等于把误写风险带进现场。 */
|
private static final List<String> FULL_PRIVILEGE_USERS = List.of("btsserver", "root");
|
/** 凭据文件相对进程工作目录定位，使开发（仓库根）与交付（应用目录）用同一个位置。 */
|
static final Path CREDENTIALS_FILE = LocalCredentials.DEFAULT_FILE;
|
|
@Override
|
public String adapterType()
|
{
|
return NewareMysqlAdapter.ADAPTER_TYPE;
|
}
|
|
@Override
|
public DeviceAdapter create(AdapterInstanceConfig config)
|
{
|
String database = option(config.sourceConfig(), DATABASE_OPTION, DEFAULT_DATABASE);
|
String user = readOnlyUser(config.sourceConfig());
|
String key = option(config.sourceConfig(), PASSWORD_ENV_OPTION,
|
NewareMysqlAdapter.DEFAULT_PASSWORD_ENV);
|
String password = LocalCredentials.resolve(key, CREDENTIALS_FILE.toAbsolutePath(), System.getenv(),
|
System::getProperty);
|
SingleConnectionVendorDataSource source = new SingleConnectionVendorDataSource(
|
jdbcUrl(config.host(), config.port(), database), user, password);
|
return NewareMysqlAdapter.create(config, source);
|
}
|
|
/**
|
* 解析厂商库账号：默认取现场取得的服务端只读账号，已知的全权限账号一律拒绝。
|
*
|
* <p>准入只按账号名拦已知的全权限账号（那不是"写一次就回不去"的能力），
|
* 真正的只读边界仍是服务端授权与语句白名单两层；这一层只是不把误配写进交付配置。
|
*/
|
static String readOnlyUser(Map<String, String> sourceConfig)
|
{
|
String user = option(sourceConfig, USER_OPTION, READ_ONLY_USER);
|
if (FULL_PRIVILEGE_USERS.contains(user.toLowerCase(Locale.ROOT)))
|
throw new DeviceAdapterException("厂商数据源只允许只读账号，拒绝全权限账号：" + user);
|
return user;
|
}
|
|
/**
|
* MySQL 5.5 那台不支持任何会话级只读机制，因此 URL 中不得出现 transaction_read_only
|
* （ADR-0062）；只读由服务端账号与语句白名单两层保证。
|
*/
|
static String jdbcUrl(String host, int port, String database)
|
{
|
return "jdbc:mysql://" + host + ":" + port + "/" + database
|
+ "?connectTimeout=5000&socketTimeout=10000&useSSL=false&allowPublicKeyRetrieval=true"
|
+ "&zeroDateTimeBehavior=convertToNull&connectionTimeZone=Asia/Hong_Kong"
|
+ "&forceConnectionTimeZoneToSession=false";
|
}
|
|
private static String option(Map<String, String> sourceConfig, String key, String fallback)
|
{
|
String value = sourceConfig.get(key);
|
return value == null || value.isBlank() ? fallback : value.trim();
|
}
|
|
/** 供装配层声明该形态的运行时能力：可发现、可观测实时值、只读。 */
|
public static AdapterCapabilities capabilities()
|
{
|
return AdapterCapabilities.observeOnly();
|
}
|
}
|
