T
LL
N
A
Y
V
H I am using HyperDrive with my Postgres db in Oracle server located in Germany with Cloudflare workers. (I am also working n Germany)Connection is made and working without problem but the response is still slow(a bit faster than direct connection). Funny thing I found is it is very fast with mobile network while it is slow with my WiFi with same running contents. (200ms vs 2 seconds). Is this because HyperDrive needs some traffic to calculate? Right now I have no users as it is in dev. Thanks!
B
J
J
A
FFFF
;
AFF
I
;||;
Zmysql2SHOW TABLESeventHandlerConnectionSELECTdrizzle
A
mysql2wrangler dev .output/server/index.mjs --assets .output/public --env development --remoteSHOW TABLES;SELECT * FROM my_table;waitUntilnodeConnectionFinalizationRegistryWeakRefconsole.logwrangler tailSELECT * FROM my_tableFinalizationRegistry createdI 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()If 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; export async function runWithDB<T>(
context: unstable_RouterContextProvider,
callback: (db: PostgresJsDatabase) => Promise<T>
): Promise<T> {
const { HYPERDRIVE } = getBindings(context);
const sql = postgres(HYPERDRIVE.connectionString, {
prepare: false,
max: 5,
fetch_types: false,
idle_timeout: 5,
connect_timeout: 5,
max_lifetime: 60,
});
try {
const db = drizzlePostgresJs(sql);
const result = await callback(db);
return result;
} catch (err) {
console.log('err', err);
throw err;
} finally {
const ctx = await getExecutionContext(context);
ctx.waitUntil(sql.end());
}
} export const getUserByEmailAddress = async (
email: string,
context: unstable_RouterContextProvider
) => {
const [user] = await runWithDB(context, async (db: PostgresJsDatabase) => {
return await db
.select()
.from(UserTable)
.where(eq(UserTable.email, email))
.limit(1);
});
return user;
};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);
}
});