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";
}