sys4/mysql
1
0
Fork 0
mirror of https://github.com/luapower/mysql.git synced 2025-01-01 14:00:27 +01:00
Code Issues Releases Wiki Activity

unimportant

Browse Source
This commit is contained in:
Cosmin Apreutesei 2021-09-16 00:36:12 +03:00
parent b0e0288c09
commit f38a4c1739
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
mysql_client.lua
View File

@ -862,7 +862,7 @@ local function get_name(buf)
end end
local function get_eof_packet(buf) local function get_eof_packet(buf)
local _ = get_u8(buf) --status: EOF buf(1) --status: EOF
local warning_count = get_u16(buf) local warning_count = get_u16(buf)
local status_flags = get_u16(buf) local status_flags = get_u16(buf)
return warning_count, status_flags return warning_count, status_flags
@ -948,7 +948,7 @@ local function recv_field_packets(self, field_count, field_attrs)
end end
local function get_err_packet(buf) local function get_err_packet(buf)
local _ = get_u8(buf) buf(1) --status: ERR
local errno = get_u16(buf) local errno = get_u16(buf)
local marker = get_u8(buf) local marker = get_u8(buf)
local sqlstate = strchar(marker) == '#' and get_bytes(buf, 5) or nil local sqlstate = strchar(marker) == '#' and get_bytes(buf, 5) or nil
@ -1083,12 +1083,13 @@ local function read_result(self, opt)
self.state = 'ready' self.state = 'ready'
return nil, get_err_packet(buf) return nil, get_err_packet(buf)
elseif typ == 'OK' then elseif typ == 'OK' then
buf(1) --status: OK
local res = {} local res = {}
res.affected_rows = get_uint(buf) res.affected_rows = get_uint(buf)
res.insert_id = get_uint(buf) res.insert_id = get_uint(buf)
res.server_status = get_u16(buf) res.server_status = get_u16(buf)
res.warning_count = get_u16(buf) res.warning_count = get_u16(buf)
res.message = get_str(buf) res.message = buf_len(buf) > 0 and get_str(buf) or nil
res.insert_id = repl(res.insert_id, 0, nil) res.insert_id = repl(res.insert_id, 0, nil)
if band(res.server_status, SERVER_MORE_RESULTS_EXISTS) ~= 0 then if band(res.server_status, SERVER_MORE_RESULTS_EXISTS) ~= 0 then
return res, 'again' return res, 'again'
@ -1243,7 +1244,7 @@ function conn:prepare(query, opt)
return nil, get_err_packet(buf) return nil, get_err_packet(buf)
end end
check(self, typ == 'OK', 'bad packet type') check(self, typ == 'OK', 'bad packet type')
buf(1) --status buf(1) --status: OK
local stmt = update({conn = self}, stmt) local stmt = update({conn = self}, stmt)
stmt.id = get_u32(buf) stmt.id = get_u32(buf)
local col_count = get_u16(buf) local col_count = get_u16(buf)