Skip to content

Commit 3941f6a

Browse files
committed
Moved dialect resolution logic into JdbcConfiguration
1 parent 4104477 commit 3941f6a

File tree

2 files changed

+16
-1
lines changed

2 files changed

+16
-1
lines changed

spring-data-jdbc-ydb/src/main/java/tech/ydb/data/repository/config/AbstractYdbJdbcConfiguration.java

+16
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package tech.ydb.data.repository.config;
22

3+
import org.springframework.beans.factory.annotation.Autowired;
34
import org.springframework.context.annotation.Configuration;
45
import org.springframework.context.annotation.Lazy;
56
import org.springframework.data.jdbc.core.convert.DefaultJdbcTypeFactory;
@@ -15,9 +16,17 @@
1516

1617
/**
1718
* @author Madiyar Nurgazin
19+
* @author Mikhail Polivakha
1820
*/
1921
@Configuration
2022
public class AbstractYdbJdbcConfiguration extends AbstractJdbcConfiguration {
23+
24+
private final YdbDialectProvider ydbDialectProvider;
25+
26+
public AbstractYdbJdbcConfiguration(YdbDialectProvider ydbDialectProvider) {
27+
this.ydbDialectProvider = ydbDialectProvider;
28+
}
29+
2130
@Override
2231
public JdbcConverter jdbcConverter(
2332
JdbcMappingContext mappingContext,
@@ -32,4 +41,11 @@ public JdbcConverter jdbcConverter(
3241

3342
return new YdbMappingJdbcConverter(mappingContext, relationResolver, conversions, jdbcTypeFactory);
3443
}
44+
45+
@Override
46+
public Dialect jdbcDialect(NamedParameterJdbcOperations operations) {
47+
return ydbDialectProvider
48+
.getDialect(operations.getJdbcOperations())
49+
.orElseThrow(() -> new IllegalStateException(String.format("Cannot determine a dialect for %s; Please provide a Dialect", operations)));
50+
}
3551
}

spring-data-jdbc-ydb/src/main/resources/META-INF/spring.factories

-1
This file was deleted.

0 commit comments

Comments
 (0)