A
FFFF
;
AFF
I
;||;
Z
mysql2SHOW TABLESeventHandlerConnectionSELECTdrizzle
A
mysql2wrangler dev .output/server/index.mjs --assets .output/public --env development --remoteSHOW TABLES;SELECT * FROM my_table;waitUntilnodeConnectionFinalizationRegistry and WeakRef to track the number of existing connections withconsole.logwrangler tailSELECT * FROM my_table query too which worked in dev and nothing.AZFinalizationRegistry created message in the log once during my initial request and after the connection count reaches around 250 to 300.AII see FinalizationRegistry created message in the log once during my initial requestAlso just an FYI that this is expected. The Workers runtime creates one isolate per metal/server (*currently) and TCP connections are sticky so you'll be routed to the same metal for a good bit after you make the initial request. The global scope is only run once at isolate startup so you'll only see that message once.
II.end(), but GC happens later.IZIIf I create a new drizzle instance with a huge schema for each Connection they are going to be kept in memory too.Sure, but the GC collector will be run more often if you're near the memory limit, so theoretically you'd see those connections being cleaned up more frequently if they were an issue. But I expect they're super lightweight anyway if the connection itself is closed.
IZSHOW TABLES
SHOW TABLES;FinalizationRegistry but I think that's a platform limitation.Iworkerd will run a GC sweep and clean things up.IFinalizationRegistry created is probably because you just get routed to a different server and a new isolate is spun up.ZSocket within mysql2 PromiseConnection.connection.stream prevents it from being cleared.Z
EAEA
FinalizationRegistryFinalizationRegistryWeakRefSELECT * FROM my_tableFinalizationRegistry createdFinalizationRegistry created.end()workerdSocketPromiseConnection.connection.stream Failed to connect to the provided database: TLS handshake failed
[SSLV3_ALERT_HANDSHAKE_FAILURE] [HANDSHAKE_FAILURE_ON_CLIENT_HELLO] [code: 2015]npx wrangler hyperdrive create testingdb --connection-string="postgres://postgres:pgpassword@iphere:5432/postgres"import { createConnection, type Connection } from "mysql2/promise";
const registry = new FinalizationRegistry((value) => {
console.log(`"${value}" was GC'd`);
});
console.log("FinalizationRegistry created");
const connections: WeakRef<Connection>[] = [];
export default defineEventHandler(async (event) => {
const { env } = event.context.cloudflare;
const connection = await createConnection({
host: env.HYPERDRIVE.host,
user: env.HYPERDRIVE.user,
password: env.HYPERDRIVE.password,
database: env.HYPERDRIVE.database,
port: env.HYPERDRIVE.port,
disableEval: true
});
try {
registry.register(connection, "MySQL2 connection");
connections.push(new WeakRef(connection));
await connection.query("SELECT * FROM `my_table`;");
event.waitUntil(connection.end());
return Response.json({
connections: connections.filter((ref) => ref.deref() !== undefined).length
});
} catch (e) {
console.error(e);
}
});event.waitUntil(
connection.end().then(() => {
(connection as any).connection.stream.destroy();
})
);