init

2026-04-29 14:58:02 +08:00
parent e729f9bd31
commit b98c66ca21
370 changed files with 55094 additions and 0 deletions
@@ -0,0 +1,59 @@
+package com.cyynote.dso;
+
+
+import java.io.InputStream;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import javax.sql.DataSource;
+
+public class DsHelper {
+    private static boolean inited = false;
+
+    public static void initData(DataSource ds) {
+        if (inited)
+            return;
+        inited = true;
+        Connection conn = null;
+        try {
+            conn = ds.getConnection();
+            PreparedStatement ps = conn.prepareStatement("SELECT name FROM sqlite_master WHERE type='table' AND name='appx';");
+            ResultSet res = ps.executeQuery();
+            if (!res.next()) {
+                String[] sqls = getSqlFromFile();
+                for (String sql : sqls)
+                    runSql(conn, sql);
+            }
+            ps.close();
+        } catch (SQLException sqlException) {
+            throw new RuntimeException(sqlException);
+        } finally {
+            try {
+                if (conn != null)
+                    conn.close();
+            } catch (SQLException sQLException) {}
+        }
+    }
+
+    private static String[] getSqlFromFile() {
+        try {
+            InputStream ins = com.cyynote.dso.DsHelper.class.getResourceAsStream("/db/schema.sql");
+            int len = ins.available();
+            byte[] bs = new byte[len];
+            ins.read(bs);
+            String str = new String(bs, "UTF-8");
+            String[] sql = str.split(";");
+            return sql;
+        } catch (Exception ex) {
+            throw new RuntimeException(ex);
+        }
+    }
+
+    private static void runSql(Connection conn, String sql) throws SQLException {
+        System.out.println(sql);
+        PreparedStatement ps = conn.prepareStatement(sql);
+        ps.executeUpdate();
+        ps.close();
+    }
+}