17
17
18
18
import static org .springframework .data .jdbc .core .convert .SqlGenerator .*;
19
19
20
- import java .sql .JDBCType ;
21
20
import java .sql .ResultSet ;
21
+ import java .sql .SQLType ;
22
22
import java .util .ArrayList ;
23
23
import java .util .Collections ;
24
24
import java .util .HashSet ;
@@ -474,17 +474,17 @@ private IdentifierProcessing getIdentifierProcessing() {
474
474
private void addConvertedPropertyValue (SqlIdentifierParameterSource parameterSource ,
475
475
RelationalPersistentProperty property , @ Nullable Object value , SqlIdentifier name ) {
476
476
477
- addConvertedValue (parameterSource , value , name , converter .getColumnType (property ), converter .getSqlType (property ));
477
+ addConvertedValue (parameterSource , value , name , converter .getColumnType (property ), converter .getTargetSqlType (property ));
478
478
}
479
479
480
480
private void addConvertedPropertyValue (SqlIdentifierParameterSource parameterSource , SqlIdentifier name , Object value ,
481
481
Class <?> javaType ) {
482
482
483
- addConvertedValue (parameterSource , value , name , javaType , JdbcUtil .sqlTypeFor (javaType ));
483
+ addConvertedValue (parameterSource , value , name , javaType , JdbcUtil .targetSqlTypeFor (javaType ));
484
484
}
485
485
486
486
private void addConvertedValue (SqlIdentifierParameterSource parameterSource , @ Nullable Object value ,
487
- SqlIdentifier paramName , Class <?> javaType , int sqlType ) {
487
+ SqlIdentifier paramName , Class <?> javaType , SQLType sqlType ) {
488
488
489
489
JdbcValue jdbcValue = converter .writeJdbcValue ( //
490
490
value , //
@@ -495,7 +495,7 @@ private void addConvertedValue(SqlIdentifierParameterSource parameterSource, @Nu
495
495
parameterSource .addValue ( //
496
496
paramName , //
497
497
jdbcValue .getValue (), //
498
- JdbcUtil . sqlTypeFor ( jdbcValue .getJdbcType ()));
498
+ jdbcValue .getJdbcType (). getVendorTypeNumber ( ));
499
499
}
500
500
501
501
private void addConvertedPropertyValuesAsList (SqlIdentifierParameterSource parameterSource ,
@@ -506,15 +506,15 @@ private void addConvertedPropertyValuesAsList(SqlIdentifierParameterSource param
506
506
for (Object id : values ) {
507
507
508
508
Class <?> columnType = converter .getColumnType (property );
509
- int sqlType = converter .getSqlType (property );
509
+ SQLType sqlType = converter .getTargetSqlType (property );
510
510
511
511
jdbcValue = converter .writeJdbcValue (id , columnType , sqlType );
512
512
convertedIds .add (jdbcValue .getValue ());
513
513
}
514
514
515
515
Assert .state (jdbcValue != null , "JdbcValue must be not null at this point. Please report this as a bug." );
516
516
517
- JDBCType jdbcType = jdbcValue .getJdbcType ();
517
+ SQLType jdbcType = jdbcValue .getJdbcType ();
518
518
int typeNumber = jdbcType == null ? JdbcUtils .TYPE_UNKNOWN : jdbcType .getVendorTypeNumber ();
519
519
520
520
parameterSource .addValue (paramName , convertedIds , typeNumber );
0 commit comments