feat: add @ccms/database

Signed-off-by: MiaoWoo <admin@yumc.pw>

packages/database/src/database.ts

@@ -0,0 +1,51 @@
+/// <reference types="@ccms/types/dist/typings/spring" />
+
+const HikariDataSource = Java.type('com.zaxxer.hikari.HikariDataSource')
+const HikariConfig = Java.type('com.zaxxer.hikari.HikariConfig')
+const JdbcTemplate = Java.type('org.springframework.jdbc.core.JdbcTemplate')
+
+/**
+ * 数据库封装类
+ */
+export class DataBase {
+    private dataSource: javax.sql.DataSource
+    private jdbcTemplate: org.springframework.jdbc.core.JdbcTemplate
+
+    constructor(url: string | javax.sql.DataSource, username?: string, password?: string) {
+        if (!url) { throw new Error('DataBase url can\'t be null!') }
+        this.createDataSource(url, username, password)
+        this.initialize()
+    }
+
+    private createDataSource(url: string | javax.sql.DataSource, username?: string, password?: string) {
+        if (typeof url === "string") {
+            if (!username || !password) {
+                throw new Error('DataBase username or password can\'t be null!')
+            }
+            let config = new HikariConfig()
+            config.setUsername(username)
+            config.setPassword(password)
+            config.setJdbcUrl(url)
+            this.dataSource = new HikariDataSource(config)
+        } else {
+            this.dataSource = url
+        }
+    }
+
+    private initialize() {
+        this.jdbcTemplate = new JdbcTemplate(this.dataSource)
+    }
+
+    /**
+     * 执行SQL查询
+     * @param sql SQL语句
+     */
+    query<T>(sql: string, ...args: any[]): Array<T> {
+        return this.jdbcTemplate.queryForList(sql, args)
+    }
+
+    close() {
+        //@ts-ignore
+        this.dataSource.close()
+    }
+}

packages/database/src/index.ts

@@ -0,0 +1,5 @@
+/// <reference types="@ccms/nashorn" />
+/// <reference types="@ccms/types/dist/typings/jdk/index" />
+
+export * from './database'
+export * from './manager'

packages/database/src/manager.ts

@@ -0,0 +1,45 @@
+import { plugin, database } from '@ccms/api'
+import { provideSingleton, inject, postConstruct, Container, ContainerInstance } from '@ccms/container'
+import { DataBase } from './database'
+
+@provideSingleton(database.DataBaseManager)
+export class DataBaseManager {
+    @inject(ContainerInstance)
+    private container: Container
+    @inject(plugin.PluginInstance)
+    private instance: any
+
+    private beanFactory: any
+    private mainDatabase: DataBase
+    private databases: { [key: string]: DataBase } = {}
+
+    @postConstruct()
+    initialize() {
+        try {
+            this.beanFactory = this.instance.getAutowireCapableBeanFactory()
+            let mainDatasource = this.beanFactory.getBean(Packages.javax.sql.DataSource.class)
+            this.mainDatabase = new DataBase(mainDatasource)
+        } catch (error) {
+            console.ex(error)
+        }
+    }
+
+    getMainDatabase() {
+        return this.mainDatabase
+    }
+
+    createDatabase(name: string, url: string, username: string, password: string) {
+        Java.synchronized(() => {
+            if (this.databases[name]) return this.databases[name]
+            return this.databases[name] = new DataBase(url, username, password)
+        }, this.databases)()
+    }
+
+    getDatabase(name: string) {
+        return this.databases[name]
+    }
+
+    disable() {
+        Object.values(this.databases).forEach((ds) => ds?.close())
+    }
+}