summaryrefslogtreecommitdiff
path: root/src/ejabberd_sm_sql.erl
diff options
context:
space:
mode:
authorAlexey Shchepin <alexey@process-one.net>2017-11-02 17:03:30 +0300
committerAlexey Shchepin <alexey@process-one.net>2017-11-02 18:21:40 +0300
commit78dfb832b8e5b711cfbbe3131493057325c0008d (patch)
tree8b3148730887908a2c6e676e6ce159b24b6d05d8 /src/ejabberd_sm_sql.erl
parentFix pkix:validate() return value (diff)
Add SQL_INSERT macro and update SQL queries to use server_host field
Diffstat (limited to '')
-rw-r--r--src/ejabberd_sm_sql.erl6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/ejabberd_sm_sql.erl b/src/ejabberd_sm_sql.erl
index 2b94064e..55e21040 100644
--- a/src/ejabberd_sm_sql.erl
+++ b/src/ejabberd_sm_sql.erl
@@ -74,6 +74,7 @@ set_session(#session{sid = {Now, Pid}, usr = {U, LServer, R},
"!pid=%(PidS)s",
"node=%(Node)s",
"username=%(U)s",
+ "server_host=%(LServer)s",
"resource=%(R)s",
"priority=%(PrioS)s",
"info=%(InfoS)s"]) of
@@ -107,7 +108,8 @@ get_sessions(LServer) ->
case ejabberd_sql:sql_query(
LServer,
?SQL("select @(usec)d, @(pid)s, @(node)s, @(username)s,"
- " @(resource)s, @(priority)s, @(info)s from sm")) of
+ " @(resource)s, @(priority)s, @(info)s from sm"
+ " where %(LServer)H")) of
{selected, Rows} ->
lists:flatmap(
fun(Row) ->
@@ -125,7 +127,7 @@ get_sessions(LUser, LServer) ->
LServer,
?SQL("select @(usec)d, @(pid)s, @(node)s, @(username)s,"
" @(resource)s, @(priority)s, @(info)s from sm"
- " where username=%(LUser)s")) of
+ " where username=%(LUser)s and %(LServer)H")) of
{selected, Rows} ->
{ok, lists:flatmap(
fun(Row) ->