scottk/clickhouse
1
0
Fork 0
mirror of https://github.com/lingble/clickhouse.git synced 2025-11-20 21:05:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

provide support for on cluster create table queries

Browse Source
This commit is contained in:
Francesco Rivola
2021-12-09 15:04:10 +01:00
parent a84d890a1d
commit caf1343c20
2 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
index.js
View File

@@ -492,7 +492,7 @@ class QueryCursor {
// Hack for Sequelize ORM // Hack for Sequelize ORM
query = query.trim().trimEnd().replace(/;$/gm, ""); query = query.trim().trimEnd().replace(/;$/gm, "");
if (query.match(/^(select|show|exists)/i)) { if (query.match(/^(select|show|exists|create)/i)) {
if ( ! R_FORMAT_PARSER.test(query)) { if ( ! R_FORMAT_PARSER.test(query)) {
query += ` FORMAT ${ClickHouse.getFullFormatName(me.format)}`; query += ` FORMAT ${ClickHouse.getFullFormatName(me.format)}`;
} }

13
test/test.js
View File

@@ -34,6 +34,19 @@ before(async () => {
await temp.query(`CREATE DATABASE ${database}`).toPromise(); await temp.query(`CREATE DATABASE ${database}`).toPromise();
}); });
describe('On cluster', () => {
// Note: this test only works with ClickHouse setup as Cluster named test_cluster
it('should be able to create table', async () => {
const query = `
CREATE TABLE ${database}.test_on_cluster ON CLUSTER test_cluster (
test String
)
ENGINE=MergeTree ORDER BY test;`;
const r = await clickhouse.query(query).toPromise();
expect(r).to.be.ok();
});
});
describe('Exec', () => { describe('Exec', () => {
it('should return not null object', async () => { it('should return not null object', async () => {
const sqlList = [ const sqlList = [