WIP SQL console: basic prototype working

src/main/java/tech/ailef/dbadmin/external/controller/DefaultDbAdminController.java

@@ -19,7 +19,6 @@
 
 package tech.ailef.dbadmin.external.controller;
 
-import java.sql.ResultSet;
 import java.sql.ResultSetMetaData;
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -57,6 +56,9 @@ import tech.ailef.dbadmin.external.DbAdminProperties;
 import tech.ailef.dbadmin.external.dbmapping.DbAdminRepository;
 import tech.ailef.dbadmin.external.dbmapping.DbObject;
 import tech.ailef.dbadmin.external.dbmapping.DbObjectSchema;
+import tech.ailef.dbadmin.external.dbmapping.query.DbQueryOutputField;
+import tech.ailef.dbadmin.external.dbmapping.query.DbQueryResult;
+import tech.ailef.dbadmin.external.dbmapping.query.DbQueryResultRow;
 import tech.ailef.dbadmin.external.dto.CompareOperator;
 import tech.ailef.dbadmin.external.dto.FacetedSearchRequest;
 import tech.ailef.dbadmin.external.dto.LogsSearchRequest;
@@ -543,10 +545,10 @@ public class DefaultDbAdminController {
 	@GetMapping("/console")
 	public String console(Model model, @RequestParam(required=false) String query) {
 		model.addAttribute("activePage", "console");
-		
+		model.addAttribute("query", query == null ? "" : query);		
 		if (query != null) {
-			List<Map<String, Object>> results = jdbTemplate.query(query, (rs, rowNum) -> {
-				Map<String, Object> result = new HashMap<>();
+			List<DbQueryResultRow> results = jdbTemplate.query(query, (rs, rowNum) -> {
+				Map<DbQueryOutputField, Object> result = new HashMap<>();
 				
 				ResultSetMetaData metaData = rs.getMetaData();
 				int cols = metaData.getColumnCount();
@@ -554,23 +556,15 @@ public class DefaultDbAdminController {
 				for (int i = 0; i < cols; i++) {
 					Object o = rs.getObject(i + 1);
 					String columnName = metaData.getColumnName(i + 1);
-					result.put(columnName, o);
+					String tableName = metaData.getTableName(i + 1);
+					DbQueryOutputField field = new DbQueryOutputField(columnName, tableName, dbAdmin);
+					
+					result.put(field, o);
 				}
 				
-				return result;
+				return new DbQueryResultRow(result, query);
 			});
-			
-			
-			/*
-			 * Print each map in a tabular format
-			 */
-			for (Map<String, Object> obj : results) {
-				System.out.println("-----------------------------------------------------------");
-				for (String key : obj.keySet()) {
-					System.out.printf("%-20s | %s\n", key, obj.get(key));
-				}
-			
-			}
+			model.addAttribute("results", new DbQueryResult(results));
 		}
 		
 		

src/main/java/tech/ailef/dbadmin/external/dbmapping/query/DbQueryOutputField.java

@@ -0,0 +1,74 @@
+package tech.ailef.dbadmin.external.dbmapping.query;
+
+import java.util.Objects;
+
+import tech.ailef.dbadmin.external.DbAdmin;
+import tech.ailef.dbadmin.external.dbmapping.DbField;
+import tech.ailef.dbadmin.external.dbmapping.DbObjectSchema;
+import tech.ailef.dbadmin.external.exceptions.DbAdminException;
+
+public class DbQueryOutputField {
+	private String name;
+	
+	private String table;
+
+	private DbField dbField;
+	
+	public DbQueryOutputField(String name, String table, DbAdmin dbAdmin) {
+		this.name = name;
+		this.table = table;
+		
+		try {
+			DbObjectSchema schema = dbAdmin.findSchemaByTableName(table);
+			DbField dbField = schema.getFieldByName(name);
+			this.dbField = dbField;
+		} catch (DbAdminException e) {
+			// We were unable to map this result column to a table, this happens
+			// for example with COUNT(*) results and similar. We ignore this
+			// as the dbField will be null and handled as such in the rest of the code
+		}
+	}
+
+	public String getName() {
+		return name;
+	}
+	
+	public String getTable() {
+		return table;
+	}
+
+	public boolean isPrimaryKey() {
+		return dbField != null && dbField.isPrimaryKey();
+	}
+	
+	public boolean isForeignKey() {
+		return dbField != null && dbField.isForeignKey();
+	}
+	
+	public boolean isBinary() {
+		return dbField != null && dbField.isBinary();
+	}
+	
+	public String getType() {
+		return "TODO TYPE";
+	}
+	
+	@Override
+	public int hashCode() {
+		return Objects.hash(name, table);
+	}
+	
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null)
+			return false;
+		if (getClass() != obj.getClass())
+			return false;
+		DbQueryOutputField other = (DbQueryOutputField) obj;
+		return Objects.equals(name, other.name) && Objects.equals(table, other.table);
+	}
+	
+	
+}

src/main/java/tech/ailef/dbadmin/external/dbmapping/query/DbQueryResult.java

@@ -0,0 +1,32 @@
+package tech.ailef.dbadmin.external.dbmapping.query;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class DbQueryResult {
+	private List<DbQueryResultRow> rows;
+
+	public DbQueryResult(List<DbQueryResultRow> rows) {
+		this.rows = rows;
+	}
+	
+	public List<DbQueryResultRow> getRows() {
+		return rows;
+	}
+	
+	public boolean isEmpty() {
+		return rows.isEmpty();
+	}
+	
+	public List<DbQueryOutputField> getSortedFields() {
+		if (isEmpty()) {
+			return new ArrayList<>();
+		} else {
+			return rows.get(0).getSortedFields();
+		}
+	}
+	
+	public int size() {
+		return rows.size();
+	}
+}

src/main/java/tech/ailef/dbadmin/external/dbmapping/query/DbQueryResultRow.java

@@ -0,0 +1,31 @@
+package tech.ailef.dbadmin.external.dbmapping.query;
+
+import java.util.List;
+import java.util.Map;
+
+public class DbQueryResultRow {
+	private Map<DbQueryOutputField, Object> values;
+	
+	private String query;
+
+	public DbQueryResultRow(Map<DbQueryOutputField, Object> values, String query) {
+		this.values = values;
+		this.query = query;
+	}
+	
+	public List<DbQueryOutputField> getSortedFields() {
+		return values.keySet().stream().sorted((f1, f2) -> f1.getName().compareTo(f2.getName())).toList();
+	}
+	
+	public String getQuery() {
+		return query;
+	}
+	
+	public Object get(DbQueryOutputField field) {
+		return values.get(field);
+	}
+	
+	
+	
+	
+}