public static String getPhoenixType()

in client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/support/TypeUtil.java [37:141]


    public static String getPhoenixType(String name, Object[] args, boolean isUnsigned, boolean limit) {
        switch (name) {
            case "BIT":
                if (limit) {
                    return joinArgs("BINARY", args);
                }
                return "BINARY";
            case "TINYINT":
                if (isUnsigned) {
                    return "UNSIGNED_TINYINT";
                }
                return "TINYINT";
            case "BOOLEAN":
            case "BOOL":
                return "BOOLEAN";
            case "SMALLINT":
                if (isUnsigned) {
                    return "UNSIGNED_SMALLINT";
                }
                return "SMALLINT";
            case "MEDIUMINT":
                return "INTEGER";
            case "INT":
            case "INTEGER":
                if (isUnsigned) {
                    return "UNSIGNED_INT";
                }
                return "INTEGER";
            case "BIGINT":
                if (isUnsigned) {
                    return "UNSIGNED_LONG";
                }
                return "BIGINT";
            case "FLOAT":
                if (isUnsigned) {
                    return "UNSIGNED_FLOAT";
                }
                return "FLOAT";
            case "DOUBLE":
                if (isUnsigned) {
                    return "UNSIGNED_DOUBLE";
                }
                return "DOUBLE";
            case "DECIMAL":
                if (limit) {
                    return joinArgs("DECIMAL", args);
                }
                return "DECIMAL";
            case "DATE":
                if (isUnsigned) {
                    return "UNSIGNED_DATE";
                }
                return "DATE";
            case "DATETIME":
            case "TIMESTAMP":
                if (isUnsigned) {
                    return "UNSIGNED_TIMESTAMP";
                }
                return "TIMESTAMP";
            case "TIME":
                if (isUnsigned) {
                    return "UNSIGNED_TIME";
                }
                return "TIME";
            case "YEAR":
                return "INTEGER";
            case "CHAR":
                if (limit) {
                    return joinArgs(name, args);
                }
                return "VARCHAR";
            case "VARCHAR":
                if (limit) {
                    return joinArgs(name, args);
                }
                return "VARCHAR";
            case "BINARY":
                if (limit) {
                    return joinArgs(name, args);
                }
                return "VARBINARY";
            case "VARBINARY":
                return "VARBINARY";
            case "TINYBLOB":
                return "VARBINARY";
            case "TINYTEXT":
                return "VARCHAR";
            case "BLOB":
                return "VARBINARY";
            case "TEXT":
                return "VARCHAR";
            case "MEDIUMBLOB":
                return "VARBINARY";
            case "MEDIUMTEXT":
                return "VARCHAR";
            case "LONGBLOB":
                return "VARBINARY";
            case "LONGTEXT":
                return "VARCHAR";
            case "ENUM":
            case "SET":
                return "VARCHAR";
        }
        return "VARCHAR";
    }