[ClickHouse] Support PostgreSQL database engine

Author: qianmoQ

src/renderer/assets/i18n/en.json

@@ -226,7 +226,8 @@
       "lazy": "Keeps tables in RAM only expiration_time_in_seconds seconds after last access. Can be used only with *Log tables.",
       "mysql": "Allows to connect to databases on a remote MySQL server and perform INSERT and SELECT queries to exchange data between ClickHouse and MySQL.",
       "materialized_mysql": "Creates ClickHouse database with all the tables existing in MySQL, and all the data in those tables. ClickHouse server works as MySQL replica. It reads binlog and performs DDL and DML queries.",
-      "materialized_postgresql": "Creates a ClickHouse database with tables from PostgreSQL database. Firstly, database with engine MaterializedPostgreSQL creates a snapshot of PostgreSQL database and loads required tables. Required tables can include any subset of tables from any subset of schemas from specified database. Along with the snapshot database engine acquires LSN and once initial dump of tables is performed - it starts pulling updates from WAL. After database is created, newly added tables to PostgreSQL database are not automatically added to replication. They have to be added manually with ATTACH TABLE db.table query."
+      "materialized_postgresql": "Creates a ClickHouse database with tables from PostgreSQL database. Firstly, database with engine MaterializedPostgreSQL creates a snapshot of PostgreSQL database and loads required tables. Required tables can include any subset of tables from any subset of schemas from specified database. Along with the snapshot database engine acquires LSN and once initial dump of tables is performed - it starts pulling updates from WAL. After database is created, newly added tables to PostgreSQL database are not automatically added to replication. They have to be added manually with ATTACH TABLE db.table query.",
+      "postgresql": "Allows to connect to databases on a remote PostgreSQL server. Supports read and write operations (SELECT and INSERT queries) to exchange data between ClickHouse and PostgreSQL."
     },
     "table": {
       "log": "Lightweight engines with minimum functionality. They’re the most effective when you need to quickly write many small tables (up to approximately 1 million rows) and read them later as a whole.",

src/renderer/assets/i18n/zh.json

@@ -227,7 +227,8 @@
       "lazy": "Keeps tables in RAM only expiration_time_in_seconds seconds after last access. Can be used only with *Log tables.",
       "mysql": "Allows to connect to databases on a remote MySQL server and perform INSERT and SELECT queries to exchange data between ClickHouse and MySQL.",
       "materialized_mysql": "Creates ClickHouse database with all the tables existing in MySQL, and all the data in those tables. ClickHouse server works as MySQL replica. It reads binlog and performs DDL and DML queries.",
-      "materialized_postgresql": "Creates a ClickHouse database with tables from PostgreSQL database. Firstly, database with engine MaterializedPostgreSQL creates a snapshot of PostgreSQL database and loads required tables. Required tables can include any subset of tables from any subset of schemas from specified database. Along with the snapshot database engine acquires LSN and once initial dump of tables is performed - it starts pulling updates from WAL. After database is created, newly added tables to PostgreSQL database are not automatically added to replication. They have to be added manually with ATTACH TABLE db.table query."
+      "materialized_postgresql": "Creates a ClickHouse database with tables from PostgreSQL database. Firstly, database with engine MaterializedPostgreSQL creates a snapshot of PostgreSQL database and loads required tables. Required tables can include any subset of tables from any subset of schemas from specified database. Along with the snapshot database engine acquires LSN and once initial dump of tables is performed - it starts pulling updates from WAL. After database is created, newly added tables to PostgreSQL database are not automatically added to replication. They have to be added manually with ATTACH TABLE db.table query.",
+      "postgresql": "Allows to connect to databases on a remote PostgreSQL server. Supports read and write operations (SELECT and INSERT queries) to exchange data between ClickHouse and PostgreSQL."
     },
     "table": {
       "log": "轻量级引擎。当您需要快速地构建多个小表(最多100万行)，然后将它们作为一个整体读取时，它们是最有效的。",

src/renderer/config/database.config.ts

@@ -5,6 +5,7 @@ import { StringUtils } from '@renderer/utils/string.utils';
 import { TranslateUtils } from '@renderer/utils/translate.utils';
 import { PropertyModel } from '@renderer/model/property.model';
 import { DefaultEngine } from "@renderer/config/engine/database/mysql/engine.database.mysql.default.config";
+import { PostgreSQLDatabaseEngine } from "@renderer/config/engine/database/engine.database.postgresql";
 
 @Injectable()
 export class DatabaseConfig {
@@ -36,6 +37,7 @@ export class DatabaseConfig {
       TranslateUtils.getValue('tooltip.database.lazy'),
       DatabaseEnum.lazy,
       null));
+
     // mysql
     const properties = new Array();
     properties.push(PropertyModel.builder('host',
@@ -62,6 +64,10 @@ export class DatabaseConfig {
       TranslateUtils.getValue('tooltip.database.mysql'),
       DatabaseEnum.mysql,
       properties));
+
+    // PostgreSQL
+    defaultEngines.push(PostgreSQLDatabaseEngine);
+
     basicDatabase.engines = defaultEngines;
     databaseEngines.push(basicDatabase);
     /**

src/renderer/config/engine/database/engine.database.postgresql.ts

@@ -0,0 +1,36 @@
+import { DatabaseModel } from "@renderer/model/database.model";
+import { TranslateUtils } from "@renderer/utils/translate.utils";
+import { DatabaseEnum } from "@renderer/enum/database.enum";
+import { PropertyModel } from "@renderer/model/property.model";
+
+const properties = new Array();
+properties.push(PropertyModel.builder('host',
+  TranslateUtils.getValue('common.host'),
+  TranslateUtils.getValue('placeholder.host'),
+  TranslateUtils.getValue('tooltip.property.host')));
+properties.push(PropertyModel.builder('port',
+  TranslateUtils.getValue('common.port'),
+  TranslateUtils.getValue('placeholder.port'),
+  TranslateUtils.getValue('tooltip.property.port')));
+properties.push(PropertyModel.builder('database',
+  TranslateUtils.getValue('common.database'),
+  TranslateUtils.getValue('placeholder.database'),
+  TranslateUtils.getValue('tooltip.property.database')));
+properties.push(PropertyModel.builder('username',
+  TranslateUtils.getValue('common.username'),
+  TranslateUtils.getValue('placeholder.username'),
+  TranslateUtils.getValue('tooltip.property.username')));
+properties.push(PropertyModel.builder('password',
+  TranslateUtils.getValue('common.password'),
+  TranslateUtils.getValue('placeholder.password'),
+  TranslateUtils.getValue('tooltip.property.password')));
+
+const PostgreSQLDatabaseEngine = DatabaseModel.builder(TranslateUtils.getValue('common.postgresql'),
+  TranslateUtils.getValue('tooltip.database.postgresql'),
+  DatabaseEnum.postgresql,
+  properties);
+PostgreSQLDatabaseEngine.supportedSource = [DatabaseEnum.clickhosue];
+
+export {
+  PostgreSQLDatabaseEngine
+}

src/renderer/services/management/metadata.service.ts

@@ -112,6 +112,7 @@ export class MetadataService extends ForwardService implements BaseService {
       case DatabaseEnum.mysql:
       case DatabaseEnum.materialized_mysql:
       case DatabaseEnum.materialized_postgresql:
+      case DatabaseEnum.postgresql:
         suffix = this.builderDatabaseMySQL(database);
         break;
     }