package com.highdatas.mdm.pojo.kettle;

import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidPooledConnection;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Primary;
import org.springframework.stereotype.Component;

import javax.sql.DataSource;
import java.sql.SQLException;
import java.util.List;

/**
 * Created by LF on 2017/4/18.
 */
@ConfigurationProperties(prefix = "master.unbigdata.db")
@Component
public class BigDataDataSourceInfo implements DataSourceInfo{
  
  @Value("${master.unbigdata.db.port}")
  private String dbPort;
  
  @Value("${master.unbigdata.db.schema}")
  private String dbName;
	
  @Value("${master.unbigdata.db.type}")
  private String dbType;
  
  @Value("${master.unbigdata.db.host}")
  private String dbHostName;

  @Value("${master.unbigdata.db.url}")
  private String dbUrl;

  @Value("${spring.datasource.username}")
  private String username;
 
  @Value("${spring.datasource.password}")
  private String password;
 
  @Value("${spring.datasource.driver-class-name}")
  private String driverClassName;
  
  private DruidDataSource datasource;
  
  public String getDbPort() {
	return dbPort;
  }

  public void setDbPort(String dbPort) {
	this.dbPort = dbPort;
  }

  public String getDbName() {
	return dbName;
  }

  public void setDbName(String dbName) {
	this.dbName = dbName;
  }

  public String getDbHostName() {
	return dbHostName;
  }

  public void setDbHostName(String dbHostName) {
	this.dbHostName = dbHostName;
  }

  public String getDbType() {
	return dbType;
  }

  public void setDbType(String dbType) {
	this.dbType = dbType;
  }

  public String getDbUrl() {
    return dbUrl;
  }

  public void setDbUrl(String dbUrl) {
    this.dbUrl = dbUrl;
  }
 
  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 getDriverClassName() {
    return driverClassName;
  }
 
  public void setDriverClassName(String driverClassName) {
    this.driverClassName = driverClassName;
  }
 
  @Bean   //声明其为Bean实例
  @Primary //在同样的DataSource中，首先使用被标注的DataSource
  public DataSource dataSource()  {
    datasource = new DruidDataSource();

    //datasource.setUrl("jdbc:mysql://localhost:3306/ssm?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC&characterEncoding=UTF8");
    //datasource.setUsername("root");
    //datasource.setPassword("123456");
    //datasource.setDriverClassName("com.mysql.cj.jdbc.Driver");
    datasource.setUrl(this.dbUrl);
    datasource.setUsername(this.username);
    datasource.setPassword(this.password);
    datasource.setDriverClassName(this.driverClassName);

    return this.datasource;
  }

  @Override
  public boolean createTable(String assembleTempTableName, List<String> fieldList) {
    return false;
  }

  @Override
  public boolean checkFieldList(String tableName, List<String> fieldList) {
    return false;
  }

  @Override
  public boolean checkTableExists(String assembleTempTableName) {
    return false;
  }

  @Override
  public List<String> getFieldsFromTable(String tableName) {
    return null;
  }

  @Bean
  @Primary
  public DruidPooledConnection conn() throws SQLException {
	  return this.datasource.getConnection();
  }

  @Override
  public boolean truncateData(String tempTableName) {
    return true;
  }

  @Override
  public boolean dropData(String tempTableName) {
    return false;
  }

}