个人中心
登录后您可以获得
免费学社区课程
下载社区电子书
参与活动得奖励
评论/点赞/收藏
立即登录
Data type mapping occurs at table creation time, after which the original type specifications are discarded. If you create a table with types used by other vendors and then issue a
DESCRIBE
tbl_name
statement, MySQL reports the table structure using the equivalent MySQL types. For example:
mysql> CREATE TABLE t (a BOOL, b FLOAT8, c LONG VARCHAR, d NUMERIC);
Query OK, 0 rows affected (0.00 sec)
mysql> DESCRIBE t;
+
| Field | Type | Null | Key | Default | Extra |
+
| a | tinyint(1) | YES | | NULL | |
| b | double | YES | | NULL | |
| c | mediumtext | YES | | NULL | |
| d | decimal(10,0) | YES | | NULL | |
+
4 rows in set (0.01 sec)
我想说的是，今天使用一套中间件对kafka消息进行解析为mysql 语句，其中遇到如下的问题，
目标表有一字段设置类型为：tinyint(1)。
源表同步消息中接收到相同类型的数据。
其中中间件中有如下解析部分：
public void setStatement(PreparedStatement statement, DatabaseType databaseType, boolean timestampChangeToLong) throws SQLException {
if (this.value == null) {
statement.setNull(this.index, this.sqlType);
} else {
switch(this.sqlType) {
case -15:
case -9:
case 1:
case 12:
case 2005:
String strVal = String.valueOf(this.value);
statement.setString(this.index, strVal);
break;
case -7:
case 16:
boolean booleanVal = (Boolean)this.value; //tinyint(1) 类型的表设计字段直接进入该case,由于接收到的消息中的数据未0或者1，直接在该未知报类转换异常。
statement.setBoolean(this.index, booleanVal);
break;
case -6:
int val2 = (Integer)this.value;
statement.setInt(this.index, val2);
break;
case -5:
long longVal = (Long)this.value;
statement.setLong(this.index, longVal);
break;
case 2:
this.setStatementDataTypeNumeric(statement);
break;
case 3:
this.setStatementDataTypeDecimal(statement, databaseType, timestampChangeToLong);
break;
case 4:
int val = (Integer)this.value;
statement.setInt(this.index, val);
break;
case 5:
int val1 = (Integer)this.value;
statement.setInt(this.index, val1);
break;
case 6:
float floatVal = (Float)this.value;
statement.setFloat(this.index, floatVal);
break;
case 8:
double doubelVal = (Double)this.value;
statement.setDouble(this.index, doubelVal);
break;
case 91:
this.setStatementDataTypeDate(statement, databaseType);
break;
case 92:
Date timeVal = (Date)this.value;
Time sqlTime = new Time(timeVal.getTime());
statement.setTime(this.index, sqlTime);
break;
case 93:
this.setStatementDataTypeTimestamp(statement, timestampChangeToLong);
break;
default:
throw new ConsumeException("sqlType " + this.sqlType + " is not support");
try {
connection = this.dataSource.getConnection();//获取连接
DatabaseMetaData metaData = connection.getMetaData();//获取元数据
String catalog = null;
String[] tableTypes = new String[]{"TABLE"};
String databasePattern = this.databaseSchema != null ? this.databaseSchema : database;
ResultSet tablesResultSet = metaData.getTables((String)catalog, databasePattern, "%", tableTypes);
Database db = new Database();
db.setName(database);
Table tablei;
while(tablesResultSet.next()) {
String tableName = tablesResultSet.getString("TABLE_NAME");
tablei = new Table(tableName);
db.addTable(tablei);
Iterator var27 = db.getTables().iterator();
while(var27.hasNext()) {
tablei = (Table)var27.next();
ResultSet columnsResultSet = metaData.getColumns((String)catalog, databasePattern, tablei.getName(), (String)null);
while(columnsResultSet.next()) {
String columnName = columnsResultSet.getString("COLUMN_NAME");
int sqlType = columnsResultSet.getInt("DATA_TYPE");//此处拿到mysql返回的字段类型
String typeName = columnsResultSet.getString("TYPE_NAME");
int size = columnsResultSet.getInt("COLUMN_SIZE");
boolean nullable = 1 == columnsResultSet.getInt("NULLABLE");
Column column = new Column();
column.setName(columnName);
column.setNullable(nullable);
column.setSqlType(sqlType);
column.setTypeName(typeName);
column.setSize(size);
tablei.addColumn(column);
var28 = db;
} catch (Exception var25) {
throw new RuntimeException("load schema exception", var25);
} finally {
if (connection != null) {
try {
connection.close();
} catch (SQLException var24) {
return var28;
也就是说，字段tinyint(1)被当做boolean类型进行了返回。导致java中Integer类型无法进行强转。
解决方法：alter talbe change `xxx` `xxx` tinyint(4) ...;即可。修改tinyint数据类型长度，mysql也就不再当做boolean类型进行返回了。
总结：Mysql表结构设计时，要避免设计为tinyint(1)这种类型，以免与boolean类型数据结构进行混淆。引起不必要bug。当然也可以总java代码中进行修改，修改后的影响，还需另外评估。
高性能 MySQL（五）：设计表结构时，如何选择数据类型会更高效？
MySQL 支持的数据类型有很多，在设计表结构时，选择正确的数据类型可以获得更高的性能。如果你还不知道如何选择，那么希望这篇文章能帮到你。
不全？MySQL数据类型精讲，定点日期枚举文本字符串，json二进制，空间，选择建议，完整详细可收藏
不全？MySQL数据类型精讲，定点日期枚举文本字符串，json二进制，空间，选择建议，完整详细可收藏
ALTER TABLE 表名 ADD FOREIGN KEY(外键名称) REFERENCES 主表名称(主键名称);
2）删除表外键：
ALTER TABLE 表名 DROP FOREIGN KEY 约束名;
3）新增主键：
ALTER TABLE 表名 ADD PRIMARY KEY(主键名称);
4）删除主键：主键只有一个直接删除即可
ALTER TABLE 表名 DROP PRIMARY KEY;
5）新增唯一约束：
ALTER TABLE 表名 ADD UNIQUE(列名称1[,列名称2,..]);
6）删除唯一约束：其实就是
