Browse Source

sql执行测试

JoeLazy 3 months ago
parent
commit
869145c3a4

+ 49 - 0
src/main/java/com/sundata/internalevaluation/calc/util/CalciteUtil.java

@@ -115,4 +115,53 @@ public class CalciteUtil {
             connection.close();
         }
     }
+
+
+    public static void main(String[] args) throws SQLException {
+        String subject = "[\n" +
+                "    {\n" +
+                "      \"subNo\": \"07cc9eca-4e66-4d1c-9dd1-fe4671c2e18b\",\n" +
+                "      \"subName\": \"Associate Degree in Health Science\"\n" +
+                "    },\n" +
+                "    {\n" +
+                "      \"subNo\": \"cda7b717-bbff-40fd-af90-7e22dcea8457\",\n" +
+                "      \"subName\": \"Associate Degree in Medicine\"\n" +
+                "    },\n" +
+                "    {\n" +
+                "      \"subNo\": \"9cf8534b-37c6-4365-8453-d1454e336992\",\n" +
+                "      \"subName\": \"Master of Biological Science\"\n" +
+                "    },\n" +
+                "    {\n" +
+                "      \"subNo\": \"b21f3d9b-670b-4819-8faa-dbb2324f522a\",\n" +
+                "      \"subName\": \"Bachelor of Criminology\"\n" +
+                "    },\n" +
+                "    {\n" +
+                "      \"subNo\": \"635c0a8a-3701-43f1-a1d6-d359465df3c6\",\n" +
+                "      \"subName\": \"Master of Teaching\"\n" +
+                "    },\n" +
+                "    {\n" +
+                "      \"subNo\": \"2aa9e2d1-5f0e-41c6-8bf5-970b08d47b67\",\n" +
+                "      \"subName\": \"Associate Degree in Creative Arts\"\n" +
+                "    }\n" +
+                "  ]";
+
+
+        CalciteUtil instance = CalciteUtil.getInstance();
+
+        SchemaPlus db1 = instance.createDatabase("db1");
+
+        instance.createTable(db1, "tab1", subject);
+
+        String sql = "";
+        sql = """
+                select "db1"."tab1"."subName" from "db1"."tab1" where "db1"."tab1"."subNo" = '635c0a8a-3701-43f1-a1d6-d359465df3c6'
+                
+                """;
+        // 执行sql
+        Object o = instance.doExecute(sql);
+
+        System.out.println(o);
+        // 关闭资源
+        instance.closeResource();
+    }
 }