package com.battery.device.neware;
|
|
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.model.AdapterCapabilities;
|
import com.battery.device.api.registry.AdapterInstanceConfig;
|
import com.battery.device.api.registry.DeviceAdapterFactory;
|
|
/**
|
* 按存储形态 {@code NEWARE_MYSQL} 构造直连厂商库的只读适配器实例。
|
*
|
* <p>连接口令只从环境变量或启动参数读取（变量名由实例配置的 {@code passwordEnv} 指定，
|
* 缺省为 {@link NewareMysqlAdapter#DEFAULT_PASSWORD_ENV}），不进数据库也不进仓库。
|
* 账号固定为现场取得的服务端只读账号，全权限账号不进入配置。
|
*/
|
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");
|
|
@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 password = credential(option(config.sourceConfig(), PASSWORD_ENV_OPTION,
|
NewareMysqlAdapter.DEFAULT_PASSWORD_ENV));
|
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;
|
}
|
|
/** 只读账号口令；启动参数优先于环境变量，便于本机排查而不必改环境。 */
|
static String credential(String variableName)
|
{
|
if (variableName == null || variableName.isBlank())
|
throw new DeviceAdapterException("未配置厂商库口令的取值变量名");
|
String value = System.getenv(variableName);
|
if (value == null || value.isBlank()) value = System.getProperty(variableName);
|
if (value == null || value.isBlank())
|
throw new DeviceAdapterException("缺少厂商库连接口令：请设置环境变量 " + variableName);
|
return value;
|
}
|
|
/**
|
* 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();
|
}
|
}
|
