feat: flask db connector

.gitignore

@@ -41,4 +41,13 @@ coverage
 packages/frontend/public/datasets/*
 
 *service.json
-*.db
+*.db
+
+for_test/
+sasl-0.3.1-cp310-cp310-win_amd64.whl
+__pycache__/
+.idea/
+connect.db
+not_sqlalchemy/
+run_flask_app.bat
+venv

apps/connector/.gitignore

@@ -0,0 +1,7 @@
+for_test/
+sasl-0.3.1-cp310-cp310-win_amd64.whl
+__pycache__/
+.idea/
+connect.db
+not_sqlalchemy/
+run_flask_app.bat

apps/connector/README.md

@@ -0,0 +1,5 @@
+# connector
+use sqlalchemy to connect database.
+
+It uses a method similar to Superset, and you can refer to its reference documentation.
+https://superset.apache.org/docs/databases/installing-database-drivers/

apps/connector/app.py

@@ -0,0 +1,36 @@
+from flask import Flask
+
+from bp import bp_Druid, bp_Drill, bp_Athena, bp_Clickhouse, bp_Oracle, bp_Sqlite, bp_SQLserver, bp_Doris, bp_Redshift, bp_Mysql, bp_Impala, bp_Kylin, bp_SparkSQL, bp_Postgres
+from bp import bp_database
+from database import init_db
+from database import db_session
+
+app = Flask(__name__)
+
+
+@app.route('/')
+def hello_world():  # put application's code here
+    return 'Hello World!'
+
+
+@app.route("/ping")
+def ping():
+    return {
+        "success": True
+    }
+
+
+@app.teardown_appcontext
+def shutdown_session(exception=None):
+    db_session.remove()
+
+
+# 注册蓝图
+app.register_blueprint(bp_database.bp)
+
+
+init_db()
+
+if __name__ == '__main__':
+    # init_db()
+    app.run(host='0.0.0.0')

apps/connector/bp/__init__.py

@@ -0,0 +1,2 @@
+# 2022/9/5
+# 17:57