package com.product.data.entity;

import com.product.common.lang.StringUtils;
import com.product.core.entity.FieldSetEntity;
import com.product.data.config.CmnConst;
import com.product.data.config.DatabaseType;

/**
 * @Author cheng
 * @Date 2022/2/5 16:45
 * @Desc 数据库配置
 */
public class DatabaseEntity {

	private Class<?> DbTypeBase;

	private int DbType;

	private String userName;

	private String passWord;

	private String ip;

	private String port;

	private String DbName;
	/**
	 * 实例名
	 * mysql oracle 无用
	 */
	private String DbInstance;

	/**
	 * 自定义参数
	 * sqlserver oracle 无用
	 */
	private String customParams;

	/**
	 * 仅Oracle使用
	 */
	private String serverName;


	/**
	 * 仅Oracle使用
	 */
	private String sid;

	public String getServerName() {
		return serverName;
	}

	public void setServerName(String serverName) {
		this.serverName = serverName;
	}

	public String getSid() {
		return sid;
	}

	public void setSid(String sid) {
		this.sid = sid;
	}

	public DatabaseEntity(int dbType) {
		DbType = dbType;
	}

	@Override
	public String toString() {
		return "DatabaseEntity{" +
				"DbType=" + DbType == null ? null : getDbType().getValue() +
				", userName='" + userName + '\'' +
				", passWord='" + passWord + '\'' +
				", ip='" + ip + '\'' +
				", port='" + port + '\'' +
				", DbName='" + DbName + '\'' +
				", DbInstance='" + DbInstance + '\'' +
				", customParams='" + customParams + '\'' +
				", serverName='" + serverName + '\'' +
				", sid='" + sid + '\'' +
				'}';
	}


	public DatabaseEntity(FieldSetEntity fse) {
		this.DbTypeBase = DatabaseType.class;
		init(fse);
	}

	protected void init(FieldSetEntity fse) {
		if (CmnConst.TABLE_PRODUCT_SYS_DATASOURCE_CONFIG.equals(fse.getTableName())) {
			DbType = fse.getInteger("datasource_type");
			userName = fse.getString("username");
			passWord = fse.getString("password");
			ip = fse.getString("ip_address");
			port = fse.getString("database_port");
			customParams = fse.getString("link_params");
			DbInstance = fse.getString("instance_name");
			return;
		}
		DbType = fse.getInteger("db_type");
		userName = fse.getString("user_name");
		passWord = fse.getString("pass_word");
		ip = fse.getString("ip");
		port = fse.getString("port");
		DbName = StringUtils.isEmpty(fse.getString("db_name")) ? fse.getString("user_name") : fse.getString("db_name");
		serverName = fse.getString("server_name");
		sid = fse.getString("sid");
		customParams = fse.getString("custom_params");
		DbInstance = fse.getString("instance");
	}

	public String getCustomParams() {

		if (this.getDbType().equals(DatabaseType.MySql) && !StringUtils.isEmpty(this.customParams)) {
			if (!"?".equals(this.customParams.substring(1))) {
				return "?" + this.customParams;
			}
		}
		return customParams == null ? "" : this.customParams;
	}

	public int getDbTypeByInt() {
		return this.DbType;
	}

	public String getOnlyKey() {
		String[] params = {DbType + "", ip, port, DbName, serverName, sid, DbInstance};
		StringBuilder str = new StringBuilder();
		for (String param : params) {
			str.append(param == null ? "" : param).append("-");
		}
		return str.toString();
	}


	public void setCustomParams(String customParams) {
		this.customParams = customParams;
	}

	public DatabaseType getDbType() {
		return DatabaseType.getDataBaseType(this.DbType);
	}

	public String getUserName() {
		return userName;
	}

	public void setUserName(String userName) {
		this.userName = userName;
	}

	public String getPassWord() {
		return passWord;
	}

	public void setPassWord(String passWord) {
		this.passWord = passWord;
	}

	public String getIp() {
		return ip;
	}

	public void setIp(String ip) {
		this.ip = ip;
	}

	public String getDbName() {
		return DbName;
	}

	public void setDbName(String dbName) {
		DbName = dbName;
	}

	public String getDbInstance() {
		return DbInstance;
	}

	public void setDbInstance(String dbInstance) {
		DbInstance = dbInstance;
	}

	public String getPort() {
		return port;
	}

	public void setPort(String port) {
		this.port = port;
	}
}