mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-10 10:58:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

more

Browse Source
This commit is contained in:
Ciro Spaciari
2025-09-09 21:48:55 -07:00
parent 6d789e2eb7
commit 75fde6ce45
2 changed files with 19 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/sql/mysql/MySQLConnection.zig
View File

@@ -358,7 +358,13 @@ pub fn getQueriesArray(this: *const @This()) JSValue {
if (this.js_value == .zero) {
return .js_undefined;
}
return js.queriesGetCached(this.js_value) orelse .js_undefined;
if (js.queriesGetCached(this.js_value)) |value| {
if (value == .zero) {
return .js_undefined;
}
return value;
}
return .js_undefined;
}
pub fn failFmt(this: *@This(), error_code: AnyMySQLError.Error, comptime fmt: [:0]const u8, args: anytype) void {
const message = bun.handleOom(std.fmt.allocPrint(bun.default_allocator, fmt, args));
@@ -387,8 +393,12 @@ pub fn failWithJSValue(this: *MySQLConnection, value: JSValue) void {
loop.enter();
defer loop.exit();
const js_error = value.toError() orelse value;
var js_error = value.toError() orelse value;
if (js_error == .zero) {
js_error = AnyMySQLError.mysqlErrorToJS(this.globalObject, "Connection closed", error.ConnectionClosed);
}
js_error.ensureStillAlive();
const queries_array = this.getQueriesArray();
queries_array.ensureStillAlive();
// this.globalObject.queueMicrotask(on_close, &[_]JSValue{ js_error, queries_array });