fix(schema-compiler): move create table name check to underlying driver for Postgres, MySQL, Oracle

Author: KSDaemon

packages/cubejs-mysql-driver/src/MySqlDriver.ts

@@ -22,6 +22,7 @@ import {
   IndexesSQL,
   DownloadTableMemoryData,
   DriverCapabilities,
+  TableColumn,
 } from '@cubejs-backend/base-driver';
 
 const GenericTypeToMySql: Record<GenericDataBaseType, string> = {
@@ -180,7 +181,7 @@ export class MySqlDriver extends BaseDriver implements DriverInterface {
 
   protected primaryKeysQuery(conditionString?: string): string | null {
     return `SELECT
-      TABLE_SCHEMA as ${this.quoteIdentifier('table_schema')}, 
+      TABLE_SCHEMA as ${this.quoteIdentifier('table_schema')},
       TABLE_NAME as ${this.quoteIdentifier('table_name')},
       COLUMN_NAME as ${this.quoteIdentifier('column_name')}
   FROM
@@ -262,6 +263,14 @@ export class MySqlDriver extends BaseDriver implements DriverInterface {
     }
   }
 
+  public async createTable(quotedTableName: string, columns: TableColumn[]): Promise<void> {
+    if (quotedTableName.length > 64) {
+      throw new Error('MySQL can not work with table names longer than 64 symbols. ' +
+        `Consider using the 'sqlAlias' attribute in your cube definition for ${quotedTableName}.`);
+    }
+    return super.createTable(quotedTableName, columns);
+  }
+
   public async query(query: string, values: unknown[]) {
     return this.withConnection(async (conn) => {
       await this.setTimeZone(conn);

packages/cubejs-oracle-driver/driver/OracleDriver.js

@@ -8,7 +8,7 @@ const {
   getEnv,
   assertDataSource,
 } = require('@cubejs-backend/shared');
-const { BaseDriver } = require('@cubejs-backend/base-driver');
+const { BaseDriver, TableColumn } = require('@cubejs-backend/base-driver');
 const oracledb = require('oracledb');
 const { reduce } = require('ramda');
 
@@ -95,13 +95,13 @@ class OracleDriver extends BaseDriver {
           , tc.data_type      "data_type"
           , c.constraint_type "key_type"
       from all_tab_columns tc
-      left join all_cons_columns cc 
-        on (tc.owner, tc.table_name, tc.column_name) 
+      left join all_cons_columns cc
+        on (tc.owner, tc.table_name, tc.column_name)
         in ((cc.owner, cc.table_name, cc.column_name))
-      left join all_constraints c 
-        on (tc.owner, tc.table_name, cc.constraint_name) 
-        in ((c.owner, c.table_name, c.constraint_name)) 
-        and c.constraint_type 
+      left join all_constraints c
+        on (tc.owner, tc.table_name, cc.constraint_name)
+        in ((c.owner, c.table_name, c.constraint_name))
+        and c.constraint_type
         in ('P','U')
       where tc.owner = user
     `);
@@ -121,6 +121,14 @@ class OracleDriver extends BaseDriver {
     await this.query('SELECT 1 FROM DUAL', {});
   }
 
+  async createTable(quotedTableName, columns) {
+    if (quotedTableName.length > 128) {
+      throw new Error('Oracle can not work with table names longer than 128 symbols. ' +
+        `Consider using the 'sqlAlias' attribute in your cube definition for ${quotedTableName}.`);
+    }
+    return super.createTable(quotedTableName, columns);
+  }
+
   async query(query, values) {
     const conn = await this.getConnectionFromPool();
 

packages/cubejs-postgres-driver/src/PostgresDriver.ts

@@ -16,7 +16,7 @@ import {
   BaseDriver,
   DownloadQueryResultsOptions, DownloadTableMemoryData, DriverInterface,
   GenericDataBaseType, IndexesSQL, TableStructure, StreamOptions,
-  StreamTableDataWithTypes, QueryOptions, DownloadQueryResultsResult, DriverCapabilities,
+  StreamTableDataWithTypes, QueryOptions, DownloadQueryResultsResult, DriverCapabilities, TableColumn,
 } from '@cubejs-backend/base-driver';
 import { QueryStream } from './QueryStream';
 
@@ -118,7 +118,7 @@ export class PostgresDriver<Config extends PostgresDriverConfiguration = Postgre
     const dataSource =
       config.dataSource ||
       assertDataSource('default');
-    
+
     this.pool = new Pool({
       idleTimeoutMillis: 30000,
       max:
@@ -146,9 +146,9 @@ export class PostgresDriver<Config extends PostgresDriverConfiguration = Postgre
   }
 
   protected primaryKeysQuery(conditionString?: string): string | null {
-    return `SELECT 
+    return `SELECT
       columns.table_schema as ${this.quoteIdentifier('table_schema')},
-      columns.table_name as ${this.quoteIdentifier('table_name')}, 
+      columns.table_name as ${this.quoteIdentifier('table_name')},
       columns.column_name as ${this.quoteIdentifier('column_name')}
     FROM information_schema.table_constraints tc
     JOIN information_schema.constraint_column_usage AS ccu USING (constraint_schema, constraint_name)
@@ -360,6 +360,14 @@ export class PostgresDriver<Config extends PostgresDriverConfiguration = Postgre
     }
   }
 
+  public async createTable(quotedTableName: string, columns: TableColumn[]): Promise<void> {
+    if (quotedTableName.length > 63) {
+      throw new Error('PostgreSQL can not work with table names longer than 63 symbols. ' +
+        `Consider using the 'sqlAlias' attribute in your cube definition for ${quotedTableName}.`);
+    }
+    return super.createTable(quotedTableName, columns);
+  }
+
   // eslint-disable-next-line @typescript-eslint/no-unused-vars
   public async query<R = unknown>(query: string, values: unknown[], options?: QueryOptions): Promise<R[]> {
     const result = await this.queryResponse(query, values);