@@ -731,7 +731,7 @@ static int State_init(StateObject *self, PyObject *args, PyObject *kwds) {
731731 {
732732 self -> structsequence_desc .name = "singlestoredb.Row" ;
733733 self -> structsequence_desc .doc = "Row of data values" ;
734- self -> structsequence_desc .n_in_sequence = self -> n_cols ;
734+ self -> structsequence_desc .n_in_sequence = ( int ) self -> n_cols ;
735735 self -> structsequence_desc .fields = calloc (self -> n_cols + 1 , sizeof (PyStructSequence_Field ));
736736 if (!self -> structsequence_desc .fields ) goto error ;
737737 for (unsigned long i = 0 ; i < self -> n_cols ; i ++ ) {
@@ -2049,7 +2049,7 @@ static PyObject *load_rowdat_1_vector(PyObject *self, PyObject *args, PyObject *
20492049 uint64_t n_rows = 0 ;
20502050 int * item_sizes = NULL ;
20512051 char * * data_formats = NULL ;
2052- void * * out_cols = NULL ;
2052+ char * * out_cols = NULL ;
20532053 int64_t * out_row_ids = NULL ;
20542054
20552055 // Parse function args.
@@ -2262,7 +2262,7 @@ static PyObject *load_rowdat_1_vector(PyObject *self, PyObject *args, PyObject *
22622262
22632263 case MYSQL_TYPE_TINY :
22642264 // TODO: missing values
2265- i8 = (is_null ) ? -127 : * (int8_t * )data ; data += 1 ;
2265+ i8 = (is_null ) ? SCHAR_MIN : * (int8_t * )data ; data += 1 ;
22662266 memcpy (out_cols [i ] + j * 1 , & i8 , 1 );
22672267 break ;
22682268
@@ -2273,7 +2273,7 @@ static PyObject *load_rowdat_1_vector(PyObject *self, PyObject *args, PyObject *
22732273 break ;
22742274
22752275 case MYSQL_TYPE_SHORT :
2276- i16 = (is_null ) ? -32768 : * (int16_t * )data ; data += 2 ;
2276+ i16 = (is_null ) ? SHRT_MIN : * (int16_t * )data ; data += 2 ;
22772277 memcpy (out_cols [i ] + j * 2 , & i16 , 2 );
22782278 break ;
22792279
@@ -2285,7 +2285,7 @@ static PyObject *load_rowdat_1_vector(PyObject *self, PyObject *args, PyObject *
22852285
22862286 case MYSQL_TYPE_LONG :
22872287 case MYSQL_TYPE_INT24 :
2288- i32 = (is_null ) ? -2147483648 : * (int32_t * )data ; data += 4 ;
2288+ i32 = (is_null ) ? INT_MIN : * (int32_t * )data ; data += 4 ;
22892289 memcpy (out_cols [i ] + j * 4 , & i32 , 4 );
22902290 break ;
22912291
@@ -2297,7 +2297,7 @@ static PyObject *load_rowdat_1_vector(PyObject *self, PyObject *args, PyObject *
22972297 break ;
22982298
22992299 case MYSQL_TYPE_LONGLONG :
2300- i64 = (is_null ) ? -2 ^ 63 : * (int64_t * )data ; data += 8 ;
2300+ i64 = (is_null ) ? LLONG_MIN : * (int64_t * )data ; data += 8 ;
23012301 memcpy (out_cols [i ] + j * 8 , & i64 , 8 );
23022302 break ;
23032303
0 commit comments