feat: 增加使用连接串的数据库查询插件，以便配置各类额外连接参数

Author: mmagi

packages/plugins/register.ts

@@ -27,6 +27,7 @@ const packagePluginList = [
   'drawing/baseChart',
   'wiki',
   'databaseConnection',
+  'databaseQuery',
   'Doc2X',
   'Doc2X/PDF2text',
   'searchXNG',

packages/plugins/src/databaseQuery/index.ts

@@ -0,0 +1,51 @@
+import { Client as PgClient } from 'pg'; // PostgreSQL 客户端
+import mysql from 'mysql2/promise'; // MySQL 客户端
+import mssql from 'mssql'; // SQL Server 客户端
+
+type Props = {
+  databaseType: string;
+  connectionString: string;
+  sql: string;
+};
+
+type Response = Promise<{
+  result: any; // 根据你的 SQL 查询结果类型调整
+}>;
+
+const main = async ({ databaseType, connectionString, sql }: Props): Response => {
+  let result;
+  try {
+    if (databaseType === 'PostgreSQL') {
+      const client = new PgClient(connectionString);
+
+      await client.connect();
+      const res = await client.query(sql);
+      result = res.rows;
+      await client.end();
+    } else if (databaseType === 'MySQL') {
+      const connection = await mysql.createConnection(connectionString);
+
+      const [rows] = await connection.execute(sql);
+      result = rows;
+      await connection.end();
+    } else if (databaseType === 'Microsoft SQL Server') {
+      const pool = await mssql.connect(connectionString);
+
+      result = await pool.query(sql);
+      await pool.close();
+    }
+    return {
+      result
+    };
+  } catch (error: unknown) {
+    // 使用类型断言来处理错误
+    if (error instanceof Error) {
+      console.error('Database query error:', error.message);
+      return Promise.reject(error.message);
+    }
+    console.error('Database query error:', error);
+    return Promise.reject('An unknown error occurred');
+  }
+};
+
+export default main;