package jnpf.database.sql.enums;

import jnpf.database.enums.DbAliasEnum;
import jnpf.database.enums.ParamEnum;
import jnpf.database.source.DbBase;
import jnpf.database.sql.enums.base.SqlFrameBase;
import jnpf.database.sql.model.DbStruct;
import lombok.AllArgsConstructor;
import lombok.Getter;

import java.util.List;
import java.util.Map;

/**
 * 金仓 SQL语句模板
 *
 * @author JNPF开发平台组 YanYu
 * @version V3.3
 * @copyright 引迈信息技术有限公司
 * @date 2022/3/17
 */
@Getter
@AllArgsConstructor
public enum SqlKingbaseESEnum implements SqlFrameBase {
    /* =============================== 系统语句 ==================================== */
    FIELDS(
            SqlPostgreSQLEnum.FIELDS.getSqlFrame()
    ){
        @Override
        public void setStructParams(String table, DbStruct dbStruct, List<String> list) {
            SqlPostgreSQLEnum.FIELDS.setStructParams(table, dbStruct, list);
        }
    },
    TABLES(
            "SELECT DISTINCT t.TABLE_NAME AS " + DbAliasEnum.TABLE_NAME.getAlias() + ",c.DESCRIPTION AS " + DbAliasEnum.TABLE_COMMENT.getAlias() + ", 0 AS " + DbAliasEnum.TABLE_SUM.getAlias() + " FROM\n" +
            "information_schema.TABLES AS t\n" +
            "LEFT JOIN\n" +
            "(SELECT * FROM PG_DESCRIPTION WHERE OBJSUBID = 0)AS c\n" +
            "ON\n" +
            "TABLE_NAME::REGCLASS::OID = C.OBJOID\n"
            + "WHERE\n" +
            " TABLE_SCHEMA = " + ParamEnum.DB_SCHEMA.getParamSign()
    ){
        @Override
        public void setStructParams(String table, DbStruct dbStruct, List<String> list) {
            list.add(dbStruct.getKingBaseDbSchema());
        }
    },
    TABLESANDVIEW(
            "SELECT t.table_name AS " + DbAliasEnum.TABLE_NAME.getAlias() +
                     ",c.DESCRIPTION AS " + DbAliasEnum.TABLE_COMMENT.getAlias() +
                    ",t.table_type AS " + DbAliasEnum.TABLE_TYPE.getAlias() +
                    "\n FROM information_schema.TABLES\n" +
                    "\tAS T LEFT JOIN " +
                    "(SELECT * FROM PG_DESCRIPTION WHERE OBJSUBID = 0)AS c\n" +
                    "ON\n" +
                    "TABLE_NAME::REGCLASS::OID = C.OBJOID\n" +
                    "WHERE\n" +
                    "\tTABLE_SCHEMA = " + ParamEnum.DB_SCHEMA.getParamSign()
    ){
        @Override
        public void setStructParams(String table, DbStruct dbStruct, List<String> list) {
            list.add(dbStruct.getKingBaseDbSchema());
        }
    },
    SqlKingbaseESEnum(
            "SELECT t.TABLE_NAME AS " + DbAliasEnum.TABLE_NAME.getAlias() + ",c.DESCRIPTION AS " + DbAliasEnum.TABLE_COMMENT.getAlias() + ", 0 AS " + DbAliasEnum.TABLE_SUM.getAlias() + " FROM\n" +
            "information_schema.TABLES AS t\n" +
            "LEFT JOIN\n" +
            "(SELECT * FROM PG_DESCRIPTION WHERE OBJSUBID = 0)AS c\n" +
            "ON\n" +
            "TABLE_NAME::REGCLASS::OID = C.OBJOID\n"
            + "WHERE\n" +
            " TABLE_SCHEMA = " + ParamEnum.DB_SCHEMA.getParamSign()
    ){
        @Override
        public void setStructParams(String table, DbStruct dbStruct, List<String> list) {
            list.add(dbStruct.getKingBaseDbSchema());
        }
    },
    TABLE(
            TABLES.sqlFrame + " AND t.TABLE_NAME = " + ParamEnum.TABLE.getParamSign()
    ){
        @Override
        public void setStructParams(String table, DbStruct dbStruct, List<String> list) {
            list.add(dbStruct.getKingBaseDbSchema());
            list.add(table);
        }
    },
    EXISTS_TABLE(
            "SELECT COUNT (*) AS TOTAL FROM (" +
            "SELECT t.TABLE_NAME AS " + DbAliasEnum.TABLE_NAME.getAlias() + " FROM\n" +
            "information_schema.TABLES AS t WHERE TABLE_SCHEMA = " + ParamEnum.DB_SCHEMA.getParamSign() +
            " and t.TABLE_NAME = " + ParamEnum.TABLE.getParamSign()
            + ") AS COUNT_TAB"
    ){
        @Override
        public void setStructParams(String table, DbStruct dbStruct, List<String> list) {
            list.add(dbStruct.getKingBaseDbSchema());
            list.add(table);
        }
    },


    /**
     * 建库
     */
    CREATE_DATABASE(
            "CREATE DATABASE WITH owner=\"{database}\" "
    ),
    DROP_DATABASE(
            "DROP DATABASE \"{database}\""
    ),
    CREATE_SCHEMA(
            "CREATE SCHEMA AUTHORIZATION \"{schema}\""
    ),
    DROP_SCHEMA(
            "DROP SCHEMA \"{schema}\" CASCADE;"
    ),

    /*==================== 操作表 ======================*/
    DROP(
            "DROP TABLE {table}"
    ),
    DROP_TABLE(
            SqlPostgreSQLEnum.DROP_TABLE
    ),
    COMMENT_COLUMN(
            SqlPostgreSQLEnum.COMMENT_COLUMN
    ),
    COMMENT_TABLE(
            SqlPostgreSQLEnum.COMMENT_TABLE
    ),
    CREATE(
            SqlPostgreSQLEnum.CREATE
    ),

    /*=============================== ALTER ====================================*/
    CREATE_TABLE(SqlPostgreSQLEnum.CREATE_TABLE.getSqlFrame()){
        @Override
        public String createIncrement(String sqlFrame,  Map<String, String> paramsMap) {
            return SqlPostgreSQLEnum.CREATE_TABLE.createIncrement(sqlFrame, paramsMap);
        }
    },
    ALTER_DROP(
            "ALTER TABLE 《schema》.{table} DROP COLUMN {column}"
    ),
    /**
     * 添加字段
     */
    ALTER_ADD(
            "ALTER TABLE 《schema》.{table} ADD COLUMN {column} {dataType}"
    ),
    /**
     * 修改字段
     */
    ALTER_TYPE(
            "ALTER TABLE 《schema》.{table} ALTER COLUMN {column} TYPE {dataType}"
    ),
    /**
     * 修改: 表名
     */
    RE_TABLE_NAME(
            SqlPostgreSQLEnum.RE_TABLE_NAME
    ),
    /*=============================== ALTER ====================================*/

    INSERT(
            "INSERT INTO 《schema》.{table} (【{column},】) VALUES (【{value},】)"
    ),
    ;
    // ALTER TABLE flow_taskoperator DROP COLUMN F_DraftData

    private final String dbEncode = DbBase.KINGBASE_ES;
    private String sqlFrame;

    SqlKingbaseESEnum(SqlFrameBase sqlEnum){
        this.sqlFrame = sqlEnum.getSqlFrame();
    }

}