Elgato_dark/ToolJet
1
0
Fork 0
mirror of https://github.com/ToolJet/ToolJet synced 2026-05-23 17:08:34 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Rescue redis exceptions

Browse source
This commit is contained in:
navaneeth 2021-04-20 15:05:01 +05:30
parent df612ac09d
commit d61b4826a5
1 changed files with 23 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
app/services/redis_query_service.rb
View file

@ -13,26 +13,34 @@ class RedisQueryService
def process
error = nil
password = source_options["password"]
password = nil if password.blank?
if $connections.include? data_source.id
connection = $connections[data_source.id][:connection]
else
connection = Redis.new(
host: source_options["host"],
port: source_options["port"],
user: source_options["username"],
password: password
)
begin
$connections[data_source.id] = { connection: connection }
if $connections.include? data_source.id
connection = $connections[data_source.id][:connection]
else
connection = Redis.new(
host: source_options["host"],
port: source_options["port"],
user: source_options["username"],
password: password
)
$connections[data_source.id] = { connection: connection }
end
query_text = options["query"]
result = connection.call(query_text.split(" "))
rescue => e
puts e
error = e.message
end
query_text = options["query"]
result = connection.call(query_text.split(" "))
{ status: 'success', data: result }
{ status: error ? 'error' : 'success', data: result, error: error }
end
end