@@ -55,8 +55,8 @@ private YdbTypesImpl() {
5555 typeBySqlType = new IntObjectHashMap <>(16 );
5656 typeBySqlType .put (Types .VARCHAR , PrimitiveType .Text );
5757 typeBySqlType .put (Types .BIGINT , PrimitiveType .Int64 );
58- typeBySqlType .put (Types .TINYINT , PrimitiveType .Int32 );
59- typeBySqlType .put (Types .SMALLINT , PrimitiveType .Int32 );
58+ typeBySqlType .put (Types .TINYINT , PrimitiveType .Int8 );
59+ typeBySqlType .put (Types .SMALLINT , PrimitiveType .Int16 );
6060 typeBySqlType .put (Types .INTEGER , PrimitiveType .Int32 );
6161 typeBySqlType .put (Types .REAL , PrimitiveType .Float );
6262 typeBySqlType .put (Types .FLOAT , PrimitiveType .Float );
@@ -77,10 +77,10 @@ private YdbTypesImpl() {
7777 typeByClass .put (long .class , PrimitiveType .Int64 );
7878 typeByClass .put (Long .class , PrimitiveType .Int64 );
7979 typeByClass .put (BigInteger .class , PrimitiveType .Int64 );
80- typeByClass .put (byte .class , PrimitiveType .Int32 );
81- typeByClass .put (Byte .class , PrimitiveType .Int32 );
82- typeByClass .put (short .class , PrimitiveType .Int32 );
83- typeByClass .put (Short .class , PrimitiveType .Int32 );
80+ typeByClass .put (byte .class , PrimitiveType .Int8 );
81+ typeByClass .put (Byte .class , PrimitiveType .Int8 );
82+ typeByClass .put (short .class , PrimitiveType .Int16 );
83+ typeByClass .put (Short .class , PrimitiveType .Int16 );
8484 typeByClass .put (int .class , PrimitiveType .Int32 );
8585 typeByClass .put (Integer .class , PrimitiveType .Int32 );
8686 typeByClass .put (float .class , PrimitiveType .Float );
0 commit comments