Skip to content

Commit 3f5fb99

Browse files
author
Philip Z
committed
fix(schema): delegate portable ID floor operations (#79)
1 parent 64b3c7b commit 3f5fb99

9 files changed

Lines changed: 36 additions & 36 deletions

File tree

‎teaql-db2/src/main/java/io/teaql/core/db2/DB2DataServiceExecutor.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,17 +27,17 @@ public void ensureSchema(UserContext context) {
2727
TeaQLDatabase dbAdapter = new TeaQLDatabase() {
2828
@Override
2929
public List<Map<String, Object>> query(String sql, Object[] args) {
30-
throw new UnsupportedOperationException();
30+
return getExecutionAdapter().queryForList(sql, args);
3131
}
3232

3333
@Override
3434
public int executeUpdate(String sql, Object[] args) {
35-
throw new UnsupportedOperationException();
35+
return getExecutionAdapter().update(sql, args);
3636
}
3737

3838
@Override
3939
public int[] batchUpdate(String sql, List<Object[]> batchArgs) {
40-
throw new UnsupportedOperationException();
40+
return getExecutionAdapter().batchUpdate(sql, batchArgs);
4141
}
4242

4343
@Override
@@ -47,7 +47,7 @@ public void execute(String sql) {
4747

4848
@Override
4949
public void executeInTransaction(Runnable action) {
50-
throw new UnsupportedOperationException();
50+
action.run();
5151
}
5252

5353
@Override

‎teaql-dm8/src/main/java/io/teaql/core/dm8/Dm8DataServiceExecutor.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,17 +27,17 @@ public void ensureSchema(UserContext context) {
2727
TeaQLDatabase dbAdapter = new TeaQLDatabase() {
2828
@Override
2929
public List<Map<String, Object>> query(String sql, Object[] args) {
30-
throw new UnsupportedOperationException();
30+
return getExecutionAdapter().queryForList(sql, args);
3131
}
3232

3333
@Override
3434
public int executeUpdate(String sql, Object[] args) {
35-
throw new UnsupportedOperationException();
35+
return getExecutionAdapter().update(sql, args);
3636
}
3737

3838
@Override
3939
public int[] batchUpdate(String sql, List<Object[]> batchArgs) {
40-
throw new UnsupportedOperationException();
40+
return getExecutionAdapter().batchUpdate(sql, batchArgs);
4141
}
4242

4343
@Override
@@ -47,7 +47,7 @@ public void execute(String sql) {
4747

4848
@Override
4949
public void executeInTransaction(Runnable action) {
50-
throw new UnsupportedOperationException();
50+
action.run();
5151
}
5252

5353
@Override

‎teaql-duckdb/src/main/java/io/teaql/core/duck/DuckDataServiceExecutor.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,17 +25,17 @@ public void ensureSchema(UserContext context) {
2525
TeaQLDatabase dbAdapter = new TeaQLDatabase() {
2626
@Override
2727
public List<Map<String, Object>> query(String sql, Object[] args) {
28-
throw new UnsupportedOperationException();
28+
return getExecutionAdapter().queryForList(sql, args);
2929
}
3030

3131
@Override
3232
public int executeUpdate(String sql, Object[] args) {
33-
throw new UnsupportedOperationException();
33+
return getExecutionAdapter().update(sql, args);
3434
}
3535

3636
@Override
3737
public int[] batchUpdate(String sql, List<Object[]> batchArgs) {
38-
throw new UnsupportedOperationException();
38+
return getExecutionAdapter().batchUpdate(sql, batchArgs);
3939
}
4040

4141
@Override
@@ -45,7 +45,7 @@ public void execute(String sql) {
4545

4646
@Override
4747
public void executeInTransaction(Runnable action) {
48-
throw new UnsupportedOperationException();
48+
action.run();
4949
}
5050

5151
@Override

‎teaql-hana/src/main/java/io/teaql/core/hana/HanaDataServiceExecutor.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,17 +27,17 @@ public void ensureSchema(UserContext context) {
2727
TeaQLDatabase dbAdapter = new TeaQLDatabase() {
2828
@Override
2929
public List<Map<String, Object>> query(String sql, Object[] args) {
30-
throw new UnsupportedOperationException();
30+
return getExecutionAdapter().queryForList(sql, args);
3131
}
3232

3333
@Override
3434
public int executeUpdate(String sql, Object[] args) {
35-
throw new UnsupportedOperationException();
35+
return getExecutionAdapter().update(sql, args);
3636
}
3737

3838
@Override
3939
public int[] batchUpdate(String sql, List<Object[]> batchArgs) {
40-
throw new UnsupportedOperationException();
40+
return getExecutionAdapter().batchUpdate(sql, batchArgs);
4141
}
4242

4343
@Override
@@ -47,7 +47,7 @@ public void execute(String sql) {
4747

4848
@Override
4949
public void executeInTransaction(Runnable action) {
50-
throw new UnsupportedOperationException();
50+
action.run();
5151
}
5252

5353
@Override

‎teaql-mssql/src/main/java/io/teaql/core/mssql/MssqlDataServiceExecutor.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,17 +28,17 @@ public void ensureSchema(UserContext context) {
2828
TeaQLDatabase dbAdapter = new TeaQLDatabase() {
2929
@Override
3030
public List<Map<String, Object>> query(String sql, Object[] args) {
31-
throw new UnsupportedOperationException();
31+
return getExecutionAdapter().queryForList(sql, args);
3232
}
3333

3434
@Override
3535
public int executeUpdate(String sql, Object[] args) {
36-
throw new UnsupportedOperationException();
36+
return getExecutionAdapter().update(sql, args);
3737
}
3838

3939
@Override
4040
public int[] batchUpdate(String sql, List<Object[]> batchArgs) {
41-
throw new UnsupportedOperationException();
41+
return getExecutionAdapter().batchUpdate(sql, batchArgs);
4242
}
4343

4444
@Override
@@ -48,7 +48,7 @@ public void execute(String sql) {
4848

4949
@Override
5050
public void executeInTransaction(Runnable action) {
51-
throw new UnsupportedOperationException();
51+
action.run();
5252
}
5353

5454
@Override

‎teaql-mysql/src/main/java/io/teaql/core/mysql/MysqlDataServiceExecutor.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -31,17 +31,17 @@ public void ensureSchema(UserContext context) {
3131
TeaQLDatabase dbAdapter = new TeaQLDatabase() {
3232
@Override
3333
public List<Map<String, Object>> query(String sql, Object[] args) {
34-
throw new UnsupportedOperationException();
34+
return getExecutionAdapter().queryForList(sql, args);
3535
}
3636

3737
@Override
3838
public int executeUpdate(String sql, Object[] args) {
39-
throw new UnsupportedOperationException();
39+
return getExecutionAdapter().update(sql, args);
4040
}
4141

4242
@Override
4343
public int[] batchUpdate(String sql, List<Object[]> batchArgs) {
44-
throw new UnsupportedOperationException();
44+
return getExecutionAdapter().batchUpdate(sql, batchArgs);
4545
}
4646

4747
@Override
@@ -51,7 +51,7 @@ public void execute(String sql) {
5151

5252
@Override
5353
public void executeInTransaction(Runnable action) {
54-
throw new UnsupportedOperationException();
54+
action.run();
5555
}
5656

5757
@Override

‎teaql-oracle/src/main/java/io/teaql/core/oracle/OracleDataServiceExecutor.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,17 +27,17 @@ public void ensureSchema(UserContext context) {
2727
TeaQLDatabase dbAdapter = new TeaQLDatabase() {
2828
@Override
2929
public List<Map<String, Object>> query(String sql, Object[] args) {
30-
throw new UnsupportedOperationException();
30+
return getExecutionAdapter().queryForList(sql, args);
3131
}
3232

3333
@Override
3434
public int executeUpdate(String sql, Object[] args) {
35-
throw new UnsupportedOperationException();
35+
return getExecutionAdapter().update(sql, args);
3636
}
3737

3838
@Override
3939
public int[] batchUpdate(String sql, List<Object[]> batchArgs) {
40-
throw new UnsupportedOperationException();
40+
return getExecutionAdapter().batchUpdate(sql, batchArgs);
4141
}
4242

4343
@Override
@@ -53,7 +53,7 @@ public void execute(String sql) {
5353

5454
@Override
5555
public void executeInTransaction(Runnable action) {
56-
throw new UnsupportedOperationException();
56+
action.run();
5757
}
5858

5959
@Override

‎teaql-postgres/src/main/java/io/teaql/core/postgres/PostgresDataServiceExecutor.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -24,17 +24,17 @@ public void ensureSchema(UserContext context) {
2424
TeaQLDatabase dbAdapter = new TeaQLDatabase() {
2525
@Override
2626
public List<Map<String, Object>> query(String sql, Object[] args) {
27-
throw new UnsupportedOperationException();
27+
return getExecutionAdapter().queryForList(sql, args);
2828
}
2929

3030
@Override
3131
public int executeUpdate(String sql, Object[] args) {
32-
throw new UnsupportedOperationException();
32+
return getExecutionAdapter().update(sql, args);
3333
}
3434

3535
@Override
3636
public int[] batchUpdate(String sql, List<Object[]> batchArgs) {
37-
throw new UnsupportedOperationException();
37+
return getExecutionAdapter().batchUpdate(sql, batchArgs);
3838
}
3939

4040
@Override
@@ -44,7 +44,7 @@ public void execute(String sql) {
4444

4545
@Override
4646
public void executeInTransaction(Runnable action) {
47-
throw new UnsupportedOperationException();
47+
action.run();
4848
}
4949

5050
@Override

‎teaql-snowflake/src/main/java/io/teaql/core/snowflake/SnowflakeDataServiceExecutor.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,17 +25,17 @@ public void ensureSchema(UserContext context) {
2525
TeaQLDatabase dbAdapter = new TeaQLDatabase() {
2626
@Override
2727
public List<Map<String, Object>> query(String sql, Object[] args) {
28-
throw new UnsupportedOperationException();
28+
return getExecutionAdapter().queryForList(sql, args);
2929
}
3030

3131
@Override
3232
public int executeUpdate(String sql, Object[] args) {
33-
throw new UnsupportedOperationException();
33+
return getExecutionAdapter().update(sql, args);
3434
}
3535

3636
@Override
3737
public int[] batchUpdate(String sql, List<Object[]> batchArgs) {
38-
throw new UnsupportedOperationException();
38+
return getExecutionAdapter().batchUpdate(sql, batchArgs);
3939
}
4040

4141
@Override
@@ -45,7 +45,7 @@ public void execute(String sql) {
4545

4646
@Override
4747
public void executeInTransaction(Runnable action) {
48-
throw new UnsupportedOperationException();
48+
action.run();
4949
}
5050

5151
@Override

0 commit comments

Comments
 (0)