executeRead when readOnly is not supported?

[ajmurmann]

I am working on a Micronaut app that uses SQLite. I am able to apply data migrations with FlyWay but when I try to read from the database using a standard findAll method via micronaut-data-connection-jdbc:4.9.0 I get an exception from JdbcConnectionUtils.java:170.

ConnectionOperations.executeRead() has a comment that explicitly says that "The connection manager might not support the read only connection!". What am I supposed to do when this happens? Is there a setting that allows me to disable readOnly connections? Do I need to create my own implementation of JdbcRepositoryOperations and set that via @RepositoryConfiguration?

Thank you for any help!

[graemerocher]

I guess you can override the findAll method and make the transaction read/write

[ajmurmann]

Ideally, I'd just override executeRead to call executeWrite and have exists() and findOne fixed as well. However, DefaultJdbcRepositoryOperations is final and @internal, so I cannot extend and override. Since AbstractSqlRepositoryOperations is public I was hoping I could just copy most of DefaultJdbcRepositoryOperations and make the modifications needed, but AbstractSqlRepositoryOperations is internal also which prevents this route as well.

As you probably know well, even implementing my own method with @query ends up calling findAll() under the hood which again causes the error.

[dstepanov]

What error are you getting?

[ajmurmann]

Here is the full error and stacktrace:

Message: Could not set JDBC Connection [HikariProxyConnection@1111208091 wrapping org.sqlite.jdbc4.JDBC4Connection@345e5a17] read-only: Cannot change read-only flag after establishing a connection. Use SQLiteConfig#setReadOnly and SQLiteConfig.createConnection().
Path Taken: new ChatChannelSocket(RedisClient redisClient,TimeProvider timeProvider,ChannelRepository channelRepository)
        at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2341)
        at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2296)
        at io.micronaut.context.DefaultBeanContext.doCreateBean(DefaultBeanContext.java:2308)
        at io.micronaut.context.DefaultBeanContext.createRegistration(DefaultBeanContext.java:3118)
        at io.micronaut.context.SingletonScope.getOrCreate(SingletonScope.java:80)
        at io.micronaut.context.DefaultBeanContext.findOrCreateSingletonBeanRegistration(DefaultBeanContext.java:3020)
        at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2981)
        at io.micronaut.context.DefaultBeanContext.resolveBeanRegistration(DefaultBeanContext.java:2747)
        at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:1745)
        at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:842)
        at io.micronaut.context.DefaultBeanContext.getBean(DefaultBeanContext.java:827)
        at io.micronaut.context.DefaultBeanContext$BeanExecutionHandle.getTarget(DefaultBeanContext.java:3912)
        at io.micronaut.web.router.AbstractRouteMatch.getTarget(AbstractRouteMatch.java:113)
        at io.micronaut.web.router.DefaultUriRouteMatch.getTarget(DefaultUriRouteMatch.java:38)
        at io.micronaut.http.server.netty.websocket.NettyServerWebSocketUpgradeHandler.writeResponse(NettyServerWebSocketUpgradeHandler.java:186)
        at io.micronaut.http.server.netty.websocket.NettyServerWebSocketUpgradeHandler.lambda$accept$2(NettyServerWebSocketUpgradeHandler.java:152)
        at io.micronaut.core.execution.ImperativeExecutionFlowImpl.onComplete(ImperativeExecutionFlowImpl.java:132)
        at io.micronaut.core.execution.DelayedExecutionFlowImpl$OnComplete.apply(DelayedExecutionFlowImpl.java:330)
        at io.micronaut.core.execution.DelayedExecutionFlowImpl.work(DelayedExecutionFlowImpl.java:51)
        at io.micronaut.core.execution.DelayedExecutionFlowImpl.complete0(DelayedExecutionFlowImpl.java:64)
        at io.micronaut.core.execution.DelayedExecutionFlowImpl.complete(DelayedExecutionFlowImpl.java:70)
        at io.micronaut.core.execution.ExecutionFlow.lambda$async$0(ExecutionFlow.java:94)
        at io.micronaut.core.execution.ImperativeExecutionFlowImpl.onComplete(ImperativeExecutionFlowImpl.java:132)
        at io.micronaut.core.execution.ExecutionFlow.lambda$async$1(ExecutionFlow.java:87)
        at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:173)
        at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:166)
        at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:469)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:566)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: io.micronaut.data.connection.exceptions.ConnectionException: Could not set JDBC Connection [HikariProxyConnection@1111208091 wrapping org.sqlite.jdbc4.JDBC4Connection@345e5a17] read-only: Cannot change read-only flag after establishing a connection. Use SQLiteConfig#setReadOnly and SQLiteConfig.createConnection().
        at io.micronaut.data.connection.support.JdbcConnectionUtils.setConnectionReadOnly(JdbcConnectionUtils.java:170)
        at io.micronaut.data.connection.support.JdbcConnectionUtils.applyReadOnly(JdbcConnectionUtils.java:75)
        at io.micronaut.data.connection.jdbc.operations.DefaultDataSourceConnectionOperations.lambda$setupConnection$0(DefaultDataSourceConnectionOperations.java:67)
        at java.base/java.util.Optional.ifPresent(Optional.java:178)
        at io.micronaut.data.connection.jdbc.operations.DefaultDataSourceConnectionOperations.setupConnection(DefaultDataSourceConnectionOperations.java:65)
        at io.micronaut.data.connection.support.AbstractConnectionOperations.executeWithNewConnection(AbstractConnectionOperations.java:142)
        at io.micronaut.data.connection.support.AbstractConnectionOperations.execute(AbstractConnectionOperations.java:90)
        at io.micronaut.data.connection.ConnectionOperations.executeRead(ConnectionOperations.java:71)
        at io.micronaut.data.jdbc.operations.DefaultJdbcRepositoryOperations.executeRead(DefaultJdbcRepositoryOperations.java:767)
        at io.micronaut.data.jdbc.operations.DefaultJdbcRepositoryOperations.findAll(DefaultJdbcRepositoryOperations.java:530)
        at io.micronaut.data.runtime.intercept.DefaultFindAllInterceptor.intercept(DefaultFindAllInterceptor.java:51)
        at io.micronaut.data.runtime.intercept.DefaultFindAllInterceptor.intercept(DefaultFindAllInterceptor.java:35)
        at io.micronaut.data.runtime.intercept.DataIntroductionAdvice.intercept(DataIntroductionAdvice.java:83)
        at io.micronaut.aop.chain.MethodInterceptorChain.proceed(MethodInterceptorChain.java:143)
        at shitchat.app.repositories.ChannelRepository$Intercepted.findAll(Unknown Source)
        at shitchat.app.ChatChannelSocket.<init>(ChatChannelSocket.kt:46)
        at shitchat.app.$ChatChannelSocket$Definition.instantiate(Unknown Source)
        at io.micronaut.context.DefaultBeanContext.resolveByBeanFactory(DefaultBeanContext.java:2326)
        ... 31 common frames omitted
Caused by: java.sql.SQLException: Cannot change read-only flag after establishing a connection. Use SQLiteConfig#setReadOnly and SQLiteConfig.createConnection().
        at org.sqlite.jdbc3.JDBC3Connection.setReadOnly(JDBC3Connection.java:146)
        at com.zaxxer.hikari.pool.ProxyConnection.setReadOnly(ProxyConnection.java:411)
        at com.zaxxer.hikari.pool.HikariProxyConnection.setReadOnly(HikariProxyConnection.java)
        at io.micronaut.data.connection.support.JdbcConnectionUtils.setConnectionReadOnly(JdbcConnectionUtils.java:167)
        ... 48 common frames omitted