Skip to content

Commit 9dfbb7a

Browse files
committed
Add the "getQuery" method to the "Command" interface
1 parent 7f36aa6 commit 9dfbb7a

File tree

9 files changed

+47
-0
lines changed

9 files changed

+47
-0
lines changed

doma-core/src/main/java/org/seasar/doma/jdbc/command/BatchModifyCommand.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,11 @@ protected BatchModifyCommand(QUERY query) {
2727
this.query = query;
2828
}
2929

30+
@Override
31+
public QUERY getQuery() {
32+
return query;
33+
}
34+
3035
@Override
3136
public int[] execute() {
3237
if (!query.isExecutable()) {
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,10 @@
11
package org.seasar.doma.jdbc.command;
22

3+
import org.seasar.doma.jdbc.query.Query;
4+
35
public interface Command<RESULT> {
46

7+
Query getQuery();
8+
59
RESULT execute();
610
}

doma-core/src/main/java/org/seasar/doma/jdbc/command/CreateCommand.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,11 @@ public CreateCommand(CreateQuery<RESULT> query) {
1515
this.query = query;
1616
}
1717

18+
@Override
19+
public CreateQuery<RESULT> getQuery() {
20+
return query;
21+
}
22+
1823
@Override
1924
public RESULT execute() {
2025
Connection connection = JdbcUtil.getConnection(query.getConfig().getDataSource());

doma-core/src/main/java/org/seasar/doma/jdbc/command/ModifyCommand.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,11 @@ protected ModifyCommand(QUERY query) {
2828
this.sql = query.getSql();
2929
}
3030

31+
@Override
32+
public QUERY getQuery() {
33+
return query;
34+
}
35+
3136
@Override
3237
public Integer execute() {
3338
if (!query.isExecutable()) {

doma-core/src/main/java/org/seasar/doma/jdbc/command/ModuleCommand.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,11 @@ protected ModuleCommand(QUERY query) {
2626
this.sql = query.getSql();
2727
}
2828

29+
@Override
30+
public QUERY getQuery() {
31+
return query;
32+
}
33+
2934
@Override
3035
public RESULT execute() {
3136
Connection connection = JdbcUtil.getConnection(query.getConfig().getDataSource());

doma-core/src/main/java/org/seasar/doma/jdbc/command/ScriptCommand.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,11 @@ public ScriptCommand(ScriptQuery query) {
2929
this.query = query;
3030
}
3131

32+
@Override
33+
public ScriptQuery getQuery() {
34+
return query;
35+
}
36+
3237
@Override
3338
public Void execute() {
3439
Config config = query.getConfig();

doma-core/src/main/java/org/seasar/doma/jdbc/command/SelectCommand.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,11 @@ public SelectCommand(SelectQuery query, ResultSetHandler<RESULT> resultSetHandle
3434
this.resultSetHandler = resultSetHandler;
3535
}
3636

37+
@Override
38+
public SelectQuery getQuery() {
39+
return query;
40+
}
41+
3742
@Override
3843
public RESULT execute() {
3944
Supplier<RESULT> supplier = null;

doma-core/src/main/java/org/seasar/doma/jdbc/command/SqlProcessorCommand.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,11 @@ public SqlProcessorCommand(
2020
this.handler = handler;
2121
}
2222

23+
@Override
24+
public SqlProcessorQuery getQuery() {
25+
return query;
26+
}
27+
2328
@Override
2429
public RESULT execute() {
2530
return handler.apply(query.getConfig(), query.getSql());

doma-core/src/test/java/org/seasar/doma/jdbc/command/SelectCommandTest.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -240,4 +240,12 @@ public void testExecute_resultStream() throws Exception {
240240
assertTrue(runtimeConfig.dataSource.connection.preparedStatement.isClosed());
241241
assertTrue(runtimeConfig.dataSource.connection.isClosed());
242242
}
243+
244+
@Test
245+
public void getGetQuery() {
246+
SqlFileSelectQuery query = new SqlFileSelectQuery();
247+
SelectCommand command =
248+
new SelectCommand<>(query, new EntityResultListHandler<>(_Emp.getSingletonInternal()));
249+
assertEquals(query, command.getQuery());
250+
}
243251
}

0 commit comments

Comments
 (0)