Skip to content

Commit b73f93e

Browse files
committed
Add count and command to result
1 parent e2a7b22 commit b73f93e

File tree

2 files changed

+10
-1
lines changed

2 files changed

+10
-1
lines changed

lib/backend.js

+9-1
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,15 @@ function Backend({
8181
if (!backend.query)
8282
return
8383

84-
backend.query.result.count = +x.utf8Slice(5, x.length - 1).split(' ').pop() // eslint-disable-line
84+
for (let i = x.length - 1; i > 0; i--) {
85+
if (x[i] === 32 && x[i + 1] < 58 && backend.query.result.count === null)
86+
backend.query.result.count = +x.utf8Slice(i + 1, x.length - 1) // eslint-disable-line
87+
if (x[i - 1] >= 65) {
88+
backend.query.result.command = x.utf8Slice(5, i)
89+
break
90+
}
91+
}
92+
8593
resolve(backend.query.stream
8694
? backend.query.result.count
8795
: backend.query.result

lib/connection.js

+1
Original file line numberDiff line numberDiff line change
@@ -88,6 +88,7 @@ export default function Connection(options = {}) {
8888

8989
function send(query, { sig, str, args = [] }) {
9090
query.result = []
91+
query.result.count = null
9192
timeout && clearTimeout(timer)
9293
!connection.ready || backend.query
9394
? queries.push(query)

0 commit comments

Comments
 (0)