Cavemanon/cavecomm
Archived
9
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

Modification to use the HandlerCollection + slight cleanup

Browse Source
This commit is contained in:
Tina_Azure
2023-03-09 19:05:33 +01:00
parent d564f4b240
commit 399d22b28f
5 changed files with 19 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
build/classes/java/main/cavecomm/Database.class
View File

Binary file not shown.

BIN
build/classes/java/main/cavecomm/HandlerCollection.class Normal file
View File

Binary file not shown.

BIN
build/classes/java/main/cavecomm/MainVerticle.class
View File

Binary file not shown.

39
src/main/java/cavecomm/Database.java
View File

@ -1,10 +1,6 @@
package cavecomm; package cavecomm;
import io.vertx.core.AsyncResult;
import io.vertx.core.Future;
import io.vertx.core.Vertx; import io.vertx.core.Vertx;
import io.vertx.core.json.JsonArray;
import io.vertx.core.json.JsonObject;
import io.vertx.ext.web.RoutingContext; import io.vertx.ext.web.RoutingContext;
import io.vertx.pgclient.PgConnectOptions; import io.vertx.pgclient.PgConnectOptions;
import io.vertx.pgclient.PgPool; import io.vertx.pgclient.PgPool;
@ -14,10 +10,15 @@ import io.vertx.sqlclient.RowSet;
import io.vertx.sqlclient.SqlClient; import io.vertx.sqlclient.SqlClient;
public class Database { public class Database {
PgConnectOptions connectOptions; public static final int OUTPUT_DATATYPE_JSON = 0;
SqlClient client; public static final int OUTPUT_DATATYPE_HTML = 1;
PoolOptions poolOptions; public static final int OUTPUT_DATATYPE_NONE = 2;
Vertx vertx;
private final PgConnectOptions connectOptions;
private final PoolOptions poolOptions;
private final Vertx vertx;
private SqlClient client;
public Database(Vertx vertx, int port, String host, String database, String user, String password) { public Database(Vertx vertx, int port, String host, String database, String user, String password) {
this.vertx = vertx; this.vertx = vertx;
@ -55,29 +56,17 @@ public class Database {
//Executes an SQL query while delivering a context to handle the data //Executes an SQL query while delivering a context to handle the data
//context output is a JSON //context output is a JSON
public void executeQuery(String query, RoutingContext rc) public void executeQuery(String query, RoutingContext rc, int outputDataType)
{ {
createClient(); createClient();
client client
.query(query) .query(query)
.execute(ar -> { .execute(ar -> {
if (ar.succeeded()) { switch (outputDataType) {
RowSet<Row> result = ar.result(); case OUTPUT_DATATYPE_JSON -> HandlerCollection.outputJSON(ar, rc);
//test output case OUTPUT_DATATYPE_HTML -> HandlerCollection.outputHTML(ar, rc);
JsonArray jsonArray = new JsonArray();
for (Row r : result) {
JsonObject jsonRow = new JsonObject();
jsonRow.put("testcolumn1", r.getJson("testcolumn1"));
jsonRow.put("column2", r.getJson("column2"));
jsonArray.add(jsonRow);
}
//sets the header to json
rc.response().putHeader("Content-Type", "application/json; charset=UTF8")
.end(jsonArray.encode());
} else {
System.out.println("Failure: " + ar.cause().getMessage());
} }
closeClient(); closeClient();
}); });
} }

16
src/main/java/cavecomm/MainVerticle.java
View File

@ -1,18 +1,9 @@
package cavecomm; package cavecomm;
import io.vertx.core.AbstractVerticle; import io.vertx.core.AbstractVerticle;
import io.vertx.core.AsyncResult;
import io.vertx.core.Handler;
import io.vertx.core.MultiMap; import io.vertx.core.MultiMap;
import io.vertx.core.json.JsonObject; import io.vertx.core.json.JsonObject;
import io.vertx.ext.web.Router; import io.vertx.ext.web.Router;
import io.vertx.ext.web.RoutingContext;
import io.vertx.pgclient.PgConnectOptions;
import io.vertx.pgclient.PgPool;
import io.vertx.sqlclient.PoolOptions;
import io.vertx.sqlclient.Row;
import io.vertx.sqlclient.RowSet;
import io.vertx.sqlclient.SqlClient;
public class MainVerticle extends AbstractVerticle { public class MainVerticle extends AbstractVerticle {
@Override @Override
@ -29,10 +20,13 @@ public class MainVerticle extends AbstractVerticle {
"testuser", "testuser",
"123"); "123");
//db.executeQuery("SELECT * FROM testtable");
router.get("/jsonTest").handler(rc -> { router.get("/jsonTest").handler(rc -> {
db.executeQuery("SELECT * FROM testtable", rc); db.executeQuery("SELECT * FROM testtable", rc, Database.OUTPUT_DATATYPE_JSON);
}
);
router.get("/htmlTest").handler(rc -> {
db.executeQuery("SELECT * FROM testtable", rc, Database.OUTPUT_DATATYPE_HTML);
} }
); );