diff options
author | Kim Alvefur <zash@zash.se> | 2012-07-28 21:26:33 +0200 |
---|---|---|
committer | Kim Alvefur <zash@zash.se> | 2012-07-28 21:26:33 +0200 |
commit | d58703f58288f9f98c2d02a40fdbc807f4da6af2 (patch) | |
tree | f3cd53c267df13746dbeda05aabd8ceaeab5e30f /plugins | |
parent | 047404cab0e0419092215e93d2b1d865d4549679 (diff) | |
download | prosody-d58703f58288f9f98c2d02a40fdbc807f4da6af2.tar.gz prosody-d58703f58288f9f98c2d02a40fdbc807f4da6af2.zip |
mod_storage_sql: Split out query handling logic from getsql() into a separate function
Diffstat (limited to 'plugins')
-rw-r--r-- | plugins/mod_storage_sql.lua | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/plugins/mod_storage_sql.lua b/plugins/mod_storage_sql.lua index 6a2d36f1..8b05c822 100644 --- a/plugins/mod_storage_sql.lua +++ b/plugins/mod_storage_sql.lua @@ -175,7 +175,7 @@ local function deserialize(t, value) end end -local function getsql(sql, ...) +local function dosql(sql, ...) if params.driver == "PostgreSQL" then sql = sql:gsub("`", "\""); end @@ -184,12 +184,15 @@ local function getsql(sql, ...) if not stmt and not test_connection() then error("connection failed"); end if not stmt then module:log("error", "QUERY FAILED: %s %s", err, debug.traceback()); return nil, err; end -- run query - local ok, err = stmt:execute(host or "", user or "", store or "", ...); + local ok, err = stmt:execute(...); if not ok and not test_connection() then error("connection failed"); end if not ok then return nil, err; end return stmt; end +local function getsql(sql, ...) + return dosql(sql, host or "", user or "", store or "", ...); +end local function setsql(sql, ...) local stmt, err = getsql(sql, ...); if not stmt then return stmt, err; end |