Skip to content

Commit e4030cf

Browse files
Add quote function
1 parent e85f5ca commit e4030cf

File tree

1 file changed

+13
-1
lines changed

1 file changed

+13
-1
lines changed

mysql/init.lua

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,19 @@ conn_mt = {
129129
end
130130
self.conn:reset(user, pass, db)
131131
self.queue:put(true)
132-
end
132+
end,
133+
quote = function(self, value)
134+
if not self.usable then
135+
return get_error(self.pool.raise, 'Connection is not usable')
136+
end
137+
if not self.queue:get() then
138+
self.queue:put(false)
139+
return get_error(self.pool.raise, 'Connection is broken')
140+
end
141+
local ret = self.conn:quote(value)
142+
self.queue:put(true)
143+
return ret
144+
end
133145
}
134146
}
135147

0 commit comments

Comments
 (0)