commit e7c1a6a: [Minor] Clickhouse: Fix extra columns that are arrays
Vsevolod Stakhov
vsevolod at highsecure.ru
Tue Apr 7 10:21:06 UTC 2020
Author: Vsevolod Stakhov
Date: 2020-04-07 11:17:09 +0100
URL: https://github.com/rspamd/rspamd/commit/e7c1a6a9a153a5832fd7748927961949b63728cb (HEAD -> master)
[Minor] Clickhouse: Fix extra columns that are arrays
---
src/plugins/lua/clickhouse.lua | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
diff --git a/src/plugins/lua/clickhouse.lua b/src/plugins/lua/clickhouse.lua
index cf70abab4..5cce0a442 100644
--- a/src/plugins/lua/clickhouse.lua
+++ b/src/plugins/lua/clickhouse.lua
@@ -1331,8 +1331,14 @@ if opts then
rspamd_logger.errx(rspamd_config, 'cannot add clickhouse extra row %s: no type or no selector',
col_name)
else
+ local is_array = false
+
+ if col_data.type:lower():match('^array') then
+ is_array = true
+ end
+
local selector = lua_selectors.create_selector_closure(rspamd_config,
- col_data.selector, col_data.delimiter or '', false)
+ col_data.selector, col_data.delimiter or '', is_array)
if not selector then
rspamd_logger.errx(rspamd_config, 'cannot add clickhouse extra row %s: bad selector: %s',
@@ -1341,7 +1347,7 @@ if opts then
settings.extra_columns[col_name] = nil
else
if not col_data.default_value then
- if col_data.type:lower():match('^array') then
+ if is_array then
col_data.default_value = {}
else
col_data.default_value = ''
More information about the Commits
mailing list