Skip to content

Commit 0870e42

Browse files
committed
adapt char type
1 parent 84f894b commit 0870e42

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/ObTableObjType.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -177,7 +177,10 @@ public void decode(ByteBuf buf, ObObj obj) {
177177
ObTableLongBlobType(24) {
178178
},
179179

180-
ObTableInvalidType(25) {
180+
ObTableCharType(25) {
181+
},
182+
183+
ObTableInvalidType(26) {
181184
};
182185

183186
private int value;
@@ -230,6 +233,8 @@ public static ObTableObjType getTableObjType(ObObj obj) {
230233
} else if (obj.isMaxObj()) {
231234
return ObTableObjType.ObTableMaxType;
232235
}
236+
} else if (objType == ObObjType.ObCharType) {
237+
return ObTableObjType.ObTableCharType;
233238
}
234239

235240
throw new IllegalArgumentException("cannot get ObTableObjType, invalid ob obj type: "
@@ -258,6 +263,7 @@ public static ObTableObjType getTableObjType(ObObj obj) {
258263
tableObjTypeMap.put(ObTableLongBlobType, ObObjType.ObLongTextType);
259264
tableObjTypeMap.put(ObTableMinType, ObObjType.ObExtendType);
260265
tableObjTypeMap.put(ObTableMaxType, ObObjType.ObExtendType);
266+
tableObjTypeMap.put(ObTableCharType, ObObjType.ObCharType);
261267
}
262268

263269
public static ObObjType getObjType(ObTableObjType tableObjType) {

0 commit comments

Comments
 (0)