Skip to content

Commit cec39cd

Browse files
committed
Convert QueryEntity to record in MySQL event listener
1 parent 3ef91a7 commit cec39cd

File tree

4 files changed

+153
-565
lines changed

4 files changed

+153
-565
lines changed

plugin/trino-mysql-event-listener/src/main/java/io/trino/plugin/eventlistener/mysql/MysqlEventListenerFactory.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,7 @@ public QueryDaoProvider(Jdbi jdbi)
113113
{
114114
this.dao = jdbi
115115
.installPlugin(new SqlObjectPlugin())
116+
.registerRowMapper(new RecordAndAnnotatedConstructorMapper())
116117
.onDemand(QueryDao.class);
117118
}
118119

plugin/trino-mysql-event-listener/src/main/java/io/trino/plugin/eventlistener/mysql/QueryDao.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
*/
1414
package io.trino.plugin.eventlistener.mysql;
1515

16-
import org.jdbi.v3.sqlobject.customizer.BindBean;
16+
import org.jdbi.v3.sqlobject.customizer.BindMethods;
1717
import org.jdbi.v3.sqlobject.statement.SqlUpdate;
1818

1919
public interface QueryDao
@@ -231,5 +231,5 @@ public interface QueryDao
231231
" :retryPolicy,\n" +
232232
" :operatorSummariesJson\n" +
233233
")")
234-
void store(@BindBean QueryEntity entity);
234+
void store(@BindMethods QueryEntity entity);
235235
}

0 commit comments

Comments
 (0)