Skip to content

Commit cde0809

Browse files
committed
qeuries fix
1 parent 6867ffd commit cde0809

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/main/java/com/github/mkopylec/sessioncouchbase/persistent/CouchbaseDao.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,12 +20,12 @@ public CouchbaseDao(CouchbaseTemplate couchbase) {
2020
}
2121

2222
public void updateSession(JsonObject attributes, String namespace, String id) {
23-
couchbase.queryN1QL(parameterized("UPDATE default USE KEYS $1 SET data." + namespace + " = $2", from(id, attributes)));
23+
couchbase.queryN1QL(parameterized("UPDATE default USE KEYS $1 SET data.`" + namespace + "` = $2", from(id, attributes)));
2424
}
2525

2626
@SuppressWarnings("unchecked")
2727
public Map<String, Object> findSessionAttributes(String id, String namespace) {
28-
List<N1qlQueryRow> attributes = couchbase.queryN1QL(parameterized("SELECT * FROM default.data." + namespace + " USE KEYS $1", from(id))).allRows();
28+
List<N1qlQueryRow> attributes = couchbase.queryN1QL(parameterized("SELECT * FROM default.data.`" + namespace + "` USE KEYS $1", from(id))).allRows();
2929
isTrue(attributes.size() < 2, "Invalid HTTP session state. Multiple namespaces '" + namespace + "' for session ID '" + id + "'");
3030
if (attributes.isEmpty()) {
3131
return null;

src/test/resources/application.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
session-couchbase:
22
timeout-in-seconds: 1800
33
persistent:
4-
namespace: test_application
4+
namespace: test-application
55
hosts: localhost
66
bucket-name: default
77
password:

0 commit comments

Comments
 (0)