Skip to content

Commit 0b044a5

Browse files
committed
Added SQLDatabaseConnection#query & SQLDatabaseConnection#exec with String param
1 parent c302a36 commit 0b044a5

2 files changed

Lines changed: 10 additions & 1 deletion

File tree

core/src/main/java/me/zort/sqllib/SQLDatabaseConnection.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -107,6 +107,7 @@ public SQLDatabaseConnection(final @NotNull SQLConnectionFactory connectionFacto
107107
*/
108108
public abstract <T> QueryRowsResult<T> query(Query query, Class<T> typeClass);
109109
public abstract QueryRowsResult<Row> query(Query query);
110+
public abstract QueryRowsResult<Row> query(String query);
110111

111112
/**
112113
* Executes given query and returns execution result.
@@ -119,6 +120,7 @@ public SQLDatabaseConnection(final @NotNull SQLConnectionFactory connectionFacto
119120
* about success state of the request.
120121
*/
121122
public abstract QueryResult exec(Query query);
123+
public abstract QueryResult exec(String query);
122124
public abstract boolean isLogSqlErrors();
123125
public abstract boolean isDebug();
124126

core/src/main/java/me/zort/sqllib/SQLDatabaseConnectionImpl.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -217,7 +217,6 @@ public final <T> T createGate(final @NotNull Class<T> mappingInterface, final @N
217217
});
218218
}
219219

220-
@SuppressWarnings("unchecked, rawtypes")
221220
@ApiStatus.Experimental
222221
public final boolean buildEntitySchema(final @NotNull String tableName, final @NotNull Class<?> entityClass) {
223222
Objects.requireNonNull(entityClass, "Entity class cannot be null!");
@@ -276,6 +275,10 @@ public QueryRowsResult<Row> query(final @NotNull Query query) {
276275
return query(query, false);
277276
}
278277

278+
public QueryRowsResult<Row> query(final @NotNull String query) {
279+
return query(() -> query);
280+
}
281+
279282
private QueryRowsResult<Row> query(final @NotNull Query query, boolean isRetry) {
280283
Objects.requireNonNull(query);
281284

@@ -327,6 +330,10 @@ public QueryResult exec(final @NotNull Query query) {
327330
return exec(query, false);
328331
}
329332

333+
public QueryResult exec(final @NotNull String query) {
334+
return exec(() -> query);
335+
}
336+
330337
private QueryResult exec(final @NotNull Query query, boolean isRetry) {
331338
if(!handleAutoReconnect()) {
332339
return new QueryResultImpl(false, "Cannot connect to database!");

0 commit comments

Comments
 (0)