|
| 1 | +import sqlite3 |
| 2 | + |
| 3 | +db = r'D:\WorkBuddyMyWorkSpace\Juggle接口编排Net6\JuggleNet6\Juggle.Api\juggle.db' |
| 4 | +conn = sqlite3.connect(db) |
| 5 | +cur = conn.cursor() |
| 6 | + |
| 7 | +# 建 t_system_config |
| 8 | +cur.execute("""CREATE TABLE IF NOT EXISTS t_system_config ( |
| 9 | + id INTEGER PRIMARY KEY AUTOINCREMENT, |
| 10 | + config_key TEXT NOT NULL, |
| 11 | + config_value TEXT, |
| 12 | + config_name TEXT, |
| 13 | + config_group TEXT, |
| 14 | + remark TEXT, |
| 15 | + deleted INTEGER NOT NULL DEFAULT 0, |
| 16 | + created_at TEXT, |
| 17 | + created_by TEXT, |
| 18 | + updated_at TEXT, |
| 19 | + updated_by TEXT |
| 20 | +)""") |
| 21 | + |
| 22 | +# 建 t_flow_test_case |
| 23 | +cur.execute("""CREATE TABLE IF NOT EXISTS t_flow_test_case ( |
| 24 | + id INTEGER PRIMARY KEY AUTOINCREMENT, |
| 25 | + flow_key TEXT NOT NULL, |
| 26 | + case_name TEXT NOT NULL, |
| 27 | + input_json TEXT, |
| 28 | + assert_json TEXT, |
| 29 | + last_run_status TEXT, |
| 30 | + last_run_time TEXT, |
| 31 | + last_run_result TEXT, |
| 32 | + remark TEXT, |
| 33 | + deleted INTEGER NOT NULL DEFAULT 0, |
| 34 | + created_at TEXT, |
| 35 | + created_by TEXT, |
| 36 | + updated_at TEXT, |
| 37 | + updated_by TEXT |
| 38 | +)""") |
| 39 | + |
| 40 | +# 建 t_token_permission(如果不存在) |
| 41 | +cur.execute("""CREATE TABLE IF NOT EXISTS t_token_permission ( |
| 42 | + id INTEGER PRIMARY KEY AUTOINCREMENT, |
| 43 | + token_id INTEGER NOT NULL, |
| 44 | + permission_type TEXT NOT NULL, |
| 45 | + resource_key TEXT NOT NULL, |
| 46 | + resource_name TEXT, |
| 47 | + deleted INTEGER NOT NULL DEFAULT 0, |
| 48 | + created_at TEXT, |
| 49 | + created_by TEXT, |
| 50 | + updated_at TEXT, |
| 51 | + updated_by TEXT |
| 52 | +)""") |
| 53 | + |
| 54 | +# 建 t_webhook(如果不存在) |
| 55 | +cur.execute("""CREATE TABLE IF NOT EXISTS t_webhook ( |
| 56 | + id INTEGER PRIMARY KEY AUTOINCREMENT, |
| 57 | + webhook_key TEXT NOT NULL, |
| 58 | + webhook_name TEXT NOT NULL, |
| 59 | + flow_key TEXT NOT NULL, |
| 60 | + flow_name TEXT, |
| 61 | + secret TEXT, |
| 62 | + allowed_method TEXT, |
| 63 | + async_mode INTEGER NOT NULL DEFAULT 0, |
| 64 | + status INTEGER NOT NULL DEFAULT 1, |
| 65 | + trigger_count INTEGER NOT NULL DEFAULT 0, |
| 66 | + last_trigger_time TEXT, |
| 67 | + remark TEXT, |
| 68 | + deleted INTEGER NOT NULL DEFAULT 0, |
| 69 | + created_at TEXT, |
| 70 | + created_by TEXT, |
| 71 | + updated_at TEXT, |
| 72 | + updated_by TEXT |
| 73 | +)""") |
| 74 | + |
| 75 | +conn.commit() |
| 76 | + |
| 77 | +# 验证所有表 |
| 78 | +cur.execute("SELECT name FROM sqlite_master WHERE type='table' ORDER BY name") |
| 79 | +all_tables = [r[0] for r in cur.fetchall()] |
| 80 | +print("数据库所有表:", all_tables) |
| 81 | +print("表总数:", len(all_tables)) |
| 82 | + |
| 83 | +conn.close() |
| 84 | +print("完成!") |
0 commit comments