fix (#17)

core/clickhouse_schema.ts

@@ -51,7 +51,7 @@ export class ClickhouseSchema<SchemaDefinition extends ChSchemaDefinition> imple
   }
 
   GetCreateTableQuery (): string {
-    if (this.options.primary_key === undefined && this.options.order_by === undefined) {
+    if (this.options.primary_key === undefined && this.options.order_by === undefined && this.options.on_cluster === undefined) {
       throw new Error('One of order_by or primary_key must be specified')
     }
 

tests/unit/clickhouse_schema.test.ts

@@ -221,4 +221,20 @@ describe('ClickhouseSchema Tests', () => {
     const query = schema.toString()
     expect(query).toEqual(expectedQuery)
   })
+
+  it('should not throw if on_cluster is specified but primary_key or order_by is not', () => {
+    const schemaDefinition = {
+      id: { type: ClickhouseTypes.CHUUID },
+      name: { type: ClickhouseTypes.CHString, default: 'John Doe' },
+      email: { type: ClickhouseTypes.CHString }
+    }
+    const options: ChSchemaOptions<typeof schemaDefinition> = {
+      table_name: 'users_table',
+      on_cluster: 'users_cluster'
+    }
+    const schema = new ClickhouseSchema(schemaDefinition, options)
+    const expectedQuery = 'CREATE TABLE IF NOT EXISTS users_table ON CLUSTER users_cluster\n(\nid UUID,\nname String DEFAULT \'John Doe\',\nemail String\n)\nENGINE = MergeTree()'
+    const query = schema.GetCreateTableQuery()
+    expect(query).toEqual(expectedQuery)
+  })
 })