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

\n in sql (array in params)

Browse Source
This commit is contained in:
Евгений Сорокин
2022-08-24 22:38:44 +03:00
parent 5e9672c5b6
commit 9e050f0a8c
2 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
index.js
View File

@@ -421,7 +421,7 @@ class QueryCursor {
} }
if (isFirstElObject) { if (isFirstElObject) {
let m = query.match(/INSERT INTO (.+?) \((.+?)\)/i); let m = query.match(/^INSERT INTO (.+?)\s*\(((\n|.)+?)\)/i);
if (m) { if (m) {
fieldList = m[2].split(',').map(s => s.trim()); fieldList = m[2].split(',').map(s => s.trim());
} else { } else {

13
test/test.js
View File

@@ -515,7 +515,8 @@ describe('queries', () => {
str String, str String,
arr Array(String), arr Array(String),
arr2 Array(Date), arr2 Array(Date),
arr3 Array(UInt8) arr3 Array(UInt8),
id1 UUID
) ENGINE=MergeTree(date, date, 8192) ) ENGINE=MergeTree(date, date, 8192)
`).toPromise(); `).toPromise();
expect(r).to.be.ok(); expect(r).to.be.ok();
@@ -526,7 +527,8 @@ describe('queries', () => {
str: 'Вам, проживающим за оргией оргию,', str: 'Вам, проживающим за оргией оргию,',
arr: [], arr: [],
arr2: ['1985-01-02', '1985-01-03'], arr2: ['1985-01-02', '1985-01-03'],
arr3: [1,2,3,4,5] arr3: [1,2,3,4,5],
id1: '102a05cb-8aaf-4f11-a442-20c3558e4384'
}, },
{ {
@@ -534,12 +536,15 @@ describe('queries', () => {
str: 'It\'s apostrophe test.', str: 'It\'s apostrophe test.',
arr: ['5670000000', 'asdas dasf. It\'s apostrophe test.'], arr: ['5670000000', 'asdas dasf. It\'s apostrophe test.'],
arr2: ['1985-02-02'], arr2: ['1985-02-02'],
arr3: [] arr3: [],
id1: 'c2103985-9a1e-4f4a-b288-b292b5209de1'
} }
]; ];
const r2 = await clickhouse.insert( const r2 = await clickhouse.insert(
'insert into test_array (date, str, arr, arr2, arr3)', `insert into test_array
(date, str, arr, arr2,
arr3, id1)`,
rows rows
).toPromise(); ).toPromise();
expect(r2).to.be.ok(); expect(r2).to.be.ok();