I mean, we'd be running the additional SQL on our side if we added it

GGerbuuun Does `PRAGMA defer_foreign_keys=ON` not disable `on update` and `on delete` acti...

G

Gerbuuun•6/4/24, 11:54 AM

Do you guys recommend not using the

on delete

on delete

on delete

on delete and

on update

on update

on update

on update features because of this? Or should I dump my current db, create a new one, and upload the data?

G

Gyurmatag•6/4/24, 1:31 PM

Hi guys! Is it possible to make a copy of an existing D1 database from the Cloudflare dashboard or with just one command?

MMax (@rozenmd)I mean, we'd be running the additional SQL on our side if we added it

I

Isaac McFadyen•6/4/24, 1:34 PM

Possibly an optional thing then?

I

Isaac McFadyen•6/4/24, 1:35 PM

This would also improve d1-jdbc-driver's introspection because currently (or well, in the v2 PR) I run pragma_table_info and then cache the results to avoid querying that again, but if a table changes it's tricky to know when to invalidate.

I

IEatBeans•6/4/24, 6:21 PM

Sentry has reported a few “D1: Internal Errors” randomly. I’m it sure which queries this is affecting but is this a known issue?

N

notjoemartinez•6/4/24, 10:13 PM

Is there any documentation on this error?

Error: D1_ERROR: The destination execution context for this RPC was canceled while the call was still running

Error: D1_ERROR: The destination execution context for this RPC was canceled while the call was still running

Error: D1_ERROR: The destination execution context for this RPC was canceled while the call was still running

Error: D1_ERROR: The destination execution context for this RPC was canceled while the call was still running the docs just define it as

Generic error.

Generic error.

Generic error.

Generic error.. I'm getting it while using the

db.batch()

db.batch()

db.batch()

db.batch() command and my code has been working fine until today. Is there a limit to how many prepared statements

db.batch

db.batch

db.batch

db.batch can run?

const transcriptPrepared = db.prepare(`
INSERT INTO transcripts
    (
        feed_id, archive_date, archive_date_time, 
        object_key, segment_start, segment_end,
        segment
    )

    VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7)
    `);

const transcriptQueriesToRun = allSegments.map(segmentObj => transcriptPrepared.bind(
        segmentObj.feed_id,
        segmentObj.archive_date,
        segmentObj.archive_date_time,
        segmentObj.object_key,
        segmentObj.segment_start,
        segmentObj.segment_end,
        segmentObj.segment
    ));

console.log("transcriptQueriesToRun.length: ", transcriptQueriesToRun.length);
console.log("transcriptQueriesToRun[0] ", JSON.stringify(transcriptQueriesToRun[0]));
if (transcriptQueriesToRun.length > 0) {
    try {
        await db.batch(transcriptQueriesToRun);

    } catch (e: any) {
        console.error({
            message: e.message
        });

        if (e instanceof Error) {
            return new Response(JSON.stringify({
                "error": e.message,
                "traceback": e.stack
            }), {
                status: 500,
                headers: getCorsHeaders()
            });
        }

    }
}

const transcriptPrepared = db.prepare(`
INSERT INTO transcripts
    (
        feed_id, archive_date, archive_date_time, 
        object_key, segment_start, segment_end,
        segment
    )

    VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7)
    `);

const transcriptQueriesToRun = allSegments.map(segmentObj => transcriptPrepared.bind(
        segmentObj.feed_id,
        segmentObj.archive_date,
        segmentObj.archive_date_time,
        segmentObj.object_key,
        segmentObj.segment_start,
        segmentObj.segment_end,
        segmentObj.segment
    ));

console.log("transcriptQueriesToRun.length: ", transcriptQueriesToRun.length);
console.log("transcriptQueriesToRun[0] ", JSON.stringify(transcriptQueriesToRun[0]));
if (transcriptQueriesToRun.length > 0) {
    try {
        await db.batch(transcriptQueriesToRun);

    } catch (e: any) {
        console.error({
            message: e.message
        });

        if (e instanceof Error) {
            return new Response(JSON.stringify({
                "error": e.message,
                "traceback": e.stack
            }), {
                status: 500,
                headers: getCorsHeaders()
            });
        }

    }
}

const transcriptPrepared = db.prepare(`
INSERT INTO transcripts
    (
        feed_id, archive_date, archive_date_time, 
        object_key, segment_start, segment_end,
        segment
    )

    VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7)
    `);

const transcriptQueriesToRun = allSegments.map(segmentObj => transcriptPrepared.bind(
        segmentObj.feed_id,
        segmentObj.archive_date,
        segmentObj.archive_date_time,
        segmentObj.object_key,
        segmentObj.segment_start,
        segmentObj.segment_end,
        segmentObj.segment
    ));

console.log("transcriptQueriesToRun.length: ", transcriptQueriesToRun.length);
console.log("transcriptQueriesToRun[0] ", JSON.stringify(transcriptQueriesToRun[0]));
if (transcriptQueriesToRun.length > 0) {
    try {
        await db.batch(transcriptQueriesToRun);

    } catch (e: any) {
        console.error({
            message: e.message
        });

        if (e instanceof Error) {
            return new Response(JSON.stringify({
                "error": e.message,
                "traceback": e.stack
            }), {
                status: 500,
                headers: getCorsHeaders()
            });
        }

    }
}

const transcriptPrepared = db.prepare(`
INSERT INTO transcripts
    (
        feed_id, archive_date, archive_date_time, 
        object_key, segment_start, segment_end,
        segment
    )

    VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7)
    `);

const transcriptQueriesToRun = allSegments.map(segmentObj => transcriptPrepared.bind(
        segmentObj.feed_id,
        segmentObj.archive_date,
        segmentObj.archive_date_time,
        segmentObj.object_key,
        segmentObj.segment_start,
        segmentObj.segment_end,
        segmentObj.segment
    ));

console.log("transcriptQueriesToRun.length: ", transcriptQueriesToRun.length);
console.log("transcriptQueriesToRun[0] ", JSON.stringify(transcriptQueriesToRun[0]));
if (transcriptQueriesToRun.length > 0) {
    try {
        await db.batch(transcriptQueriesToRun);

    } catch (e: any) {
        console.error({
            message: e.message
        });

        if (e instanceof Error) {
            return new Response(JSON.stringify({
                "error": e.message,
                "traceback": e.stack
            }), {
                status: 500,
                headers: getCorsHeaders()
            });
        }

    }
}

N

notjoemartinez•6/4/24, 10:14 PM

This is the full traceback:

Error: D1_ERROR: The destination execution context for this RPC was canceled while the call was still running.\n    at D1Database._sendOrThrow (cloudflare-internal:d1-api:66:19)\n    at async D1Database.batch (cloudflare-internal:d1-api:36:23)\n    at async updateTranscripts (index.js:15762:9)\n    at async Object.fetch (index.js:16415:16)

Error: D1_ERROR: The destination execution context for this RPC was canceled while the call was still running.\n    at D1Database._sendOrThrow (cloudflare-internal:d1-api:66:19)\n    at async D1Database.batch (cloudflare-internal:d1-api:36:23)\n    at async updateTranscripts (index.js:15762:9)\n    at async Object.fetch (index.js:16415:16)

Error: D1_ERROR: The destination execution context for this RPC was canceled while the call was still running.\n    at D1Database._sendOrThrow (cloudflare-internal:d1-api:66:19)\n    at async D1Database.batch (cloudflare-internal:d1-api:36:23)\n    at async updateTranscripts (index.js:15762:9)\n    at async Object.fetch (index.js:16415:16)

Error: D1_ERROR: The destination execution context for this RPC was canceled while the call was still running.\n    at D1Database._sendOrThrow (cloudflare-internal:d1-api:66:19)\n    at async D1Database.batch (cloudflare-internal:d1-api:36:23)\n    at async updateTranscripts (index.js:15762:9)\n    at async Object.fetch (index.js:16415:16)

N

notjoemartinez•6/4/24, 11:50 PM

nvm, my insert query was either going over the 30 second query limit. I fixed it by deleting some triggers that were slowing down the inserts. https://developers.cloudflare.com/d1/platform/limits/

Cloudflare Docs

Limits · Cloudflare D1 docs

If you would like to explore other storage solutions for your application, Cloudflare also offers Workers KV, Durable Objects, and R2.

MMax (@rozenmd)working on that - we just shipped a query param to let you skip pages (and go ba...

M

Max (@rozenmd)OP•6/5/24, 7:47 AM

going to make the dashboard table UI look more like DataGrip by the end of the summer

GGerbuuun Does `PRAGMA defer_foreign_keys=ON` not disable `on update` and `on delete` acti...

G

Gerbuuun•6/5/24, 3:37 PM

Has really nobody ran into this problem?

F

Foywards Bound•6/5/24, 4:32 PM

I have a TypeScript worker bound to a D1 database and I'm trying to insert a row like so:

let r : D1Response = await DATABASE.prepare(query).bind(id,name,type,created_at).run();
console.log("Response success: " + r.success);
console.log("Response error: " + r.error);

let r : D1Response = await DATABASE.prepare(query).bind(id,name,type,created_at).run();
console.log("Response success: " + r.success);
console.log("Response error: " + r.error);

let r : D1Response = await DATABASE.prepare(query).bind(id,name,type,created_at).run();
console.log("Response success: " + r.success);
console.log("Response error: " + r.error);

let r : D1Response = await DATABASE.prepare(query).bind(id,name,type,created_at).run();
console.log("Response success: " + r.success);
console.log("Response error: " + r.error);

but it never gets to the logging part, I'm guessing the promise is not returning

F

Foywards Bound•6/5/24, 4:44 PM

I added some more logging and awaiting and now I'm seeing it's a syntax error, oops!

F

Foywards Bound•6/5/24, 4:44 PM

const query = "INSERT INTO services(id,name,type,created_at)"
    + " VALUES (?,?,?,?)"
    + " ON CONFLICT (id) UPDATE" 
    + " SET name = excluded.name, type = excluded.type"
    + " WHERE name != excluded.name OR type != excluded.type";

const query = "INSERT INTO services(id,name,type,created_at)"
    + " VALUES (?,?,?,?)"
    + " ON CONFLICT (id) UPDATE" 
    + " SET name = excluded.name, type = excluded.type"
    + " WHERE name != excluded.name OR type != excluded.type";

const query = "INSERT INTO services(id,name,type,created_at)"
    + " VALUES (?,?,?,?)"
    + " ON CONFLICT (id) UPDATE" 
    + " SET name = excluded.name, type = excluded.type"
    + " WHERE name != excluded.name OR type != excluded.type";

const query = "INSERT INTO services(id,name,type,created_at)"
    + " VALUES (?,?,?,?)"
    + " ON CONFLICT (id) UPDATE" 
    + " SET name = excluded.name, type = excluded.type"
    + " WHERE name != excluded.name OR type != excluded.type";

F

Foywards Bound•6/5/24, 4:49 PM

What am I missing? This should be valid SQLite, no? https://www.sqlite.org/lang_upsert.html

F

Foywards Bound•6/5/24, 4:53 PM

I tried in the D1 Console and

INSERT INTO services (id,name,type,created_at) VALUES ("1", "2", "3", "4") ON CONFLICT (id) UPDATE SET name = excluded.name, type = excluded.type WHERE name != excluded.name OR type != excluded.type

INSERT INTO services (id,name,type,created_at) VALUES ("1", "2", "3", "4") ON CONFLICT (id) UPDATE SET name = excluded.name, type = excluded.type WHERE name != excluded.name OR type != excluded.type

INSERT INTO services (id,name,type,created_at) VALUES ("1", "2", "3", "4") ON CONFLICT (id) UPDATE SET name = excluded.name, type = excluded.type WHERE name != excluded.name OR type != excluded.type

INSERT INTO services (id,name,type,created_at) VALUES ("1", "2", "3", "4") ON CONFLICT (id) UPDATE SET name = excluded.name, type = excluded.type WHERE name != excluded.name OR type != excluded.type

does not work

F

Foywards Bound•6/5/24, 4:53 PM

However, this works:

INSERT INTO services (id,name,type,created_at) VALUES ("1", "2", "3", "4") ON CONFLICT DO NOTHING

INSERT INTO services (id,name,type,created_at) VALUES ("1", "2", "3", "4") ON CONFLICT DO NOTHING

INSERT INTO services (id,name,type,created_at) VALUES ("1", "2", "3", "4") ON CONFLICT DO NOTHING

INSERT INTO services (id,name,type,created_at) VALUES ("1", "2", "3", "4") ON CONFLICT DO NOTHING

F

Foywards Bound•6/5/24, 4:54 PM

So... does D1 not fully support SQLite? The UPSERT feature seems to be unimplemented?

F

Foywards Bound•6/5/24, 4:54 PM

Or am I missing something obvious?

F

Foywards Bound•6/5/24, 6:09 PM

I am missing something obvious. DO!

A

alok•6/5/24, 8:09 PM

I wrote the following small helper class to make it easier to batch D1 queries: https://github.com/zxsdotch/d1-batch. Let me know if you find it useful or if you would like me to add more features.

D

dpkp•6/5/24, 8:52 PM

Any recommendations for using d1 data with an external analytics system like metabase?

H

Hannes•6/6/24, 8:58 AM

Hi, I'm monitoring my services with Sentry and I'm getting a few D1 errors every day, although there's not a lot of traffic on the site. I'm worried it will become worse once there are more visitors?
The errors I'm seeing are:
D1_ERROR: Network connection lost.
D1_ERROR: internal error

HHannes Hi, I'm monitoring my services with Sentry and I'm getting a few D1 errors every...

M

Max (@rozenmd)OP•6/6/24, 10:06 AM

Are they particularly intensive queries? mostly reads, or writes?

MMax (@rozenmd)Are they particularly intensive queries? mostly reads, or writes?

H

Hannes•6/6/24, 10:14 AM

Interesting. I'm only seeing it on reads, though that might be due to the much bigger number of reads than writes. It is difficult to say which queries, because I'm using Prisma ORM and it does all the SQL under the hood. I believe that it does happen for quite simple queries, too. Like (pseudo sql)

SELECT field1, field2, field3, field4, field5 FROM table WHERE field9 = "k" OR field9 IS NULL

SELECT field1, field2, field3, field4, field5 FROM table WHERE field9 = "k" OR field9 IS NULL

.

M

Max (@rozenmd)OP•6/6/24, 10:17 AM

Network connection lost.

Network connection lost.

in particular is the error a DO client throws when it disconnects from the DO - as long as it's a SELECT, it's safe to retry

MMax (@rozenmd)`Network connection lost.` in particular is the error a DO client throws when it...

H

Hannes•6/6/24, 12:38 PM

Ok, thanks. Unsure how to implement that, though, as requests are handled entirely by prisma. I'll see if I open an issue over there.
Is that expected, though, or is it an error that you're monitoring and expecting to improve?

HHannes Ok, thanks. Unsure how to implement that, though, as requests are handled entire...

M

Max (@rozenmd)OP•6/6/24, 6:09 PM

I'd probably wrap your prisma calls in a try/catch (if its throwing an error) and try again - we're monitoring all errors and will find fixes for them over time

MMax (@rozenmd)I'd probably wrap your prisma calls in a try/catch (if its throwing an error) an...

H

Hannes•6/6/24, 6:13 PM

Thanks for the info. My application more than 1000 prisma calls, so that'd probably have to be a more generic approach

But great to know that you're monitoring this.

F

Foywards Bound•6/6/24, 11:44 PM

Is there a best practice around primary keys / auto incrementing ids in D1?

B

berniesumption•6/7/24, 8:58 AM

To flesh out Alexander's answer a bit, since we're using SQLite, every row will have an auto-incrementing ID by default. If you define your own

INTEGER PRIMARY KEY

INTEGER PRIMARY KEY

column, that's the auto-incrementing ID. If you don't, you'll get a default one called

ROWID

ROWID

that you can use for queries. You can opt out by defining the table as

WITHOUT ROWID

WITHOUT ROWID

but that comes with some additional constraints - https://sqlite.org/withoutrowid.html - and you should only do that if you know what you're doing.

So SQLite, and D1, support auto-incrementing IDs just fine.

Separately, there are all kinds of reasons why UUIDs are preferable to auto-incrementing IDs for most apps regardless of the database engine. So it is good advice to use UUIDs by default unless you have a good reason to use auto-incrementing integers and understand the potential pitfalls with them (e.g. enabling id enumeration attacks and leaking information about the size of tables).

J

jepcd•6/7/24, 9:15 AM

Hi, is there a limit on the number of statements in a batch call?

G

Gerbuuun•6/7/24, 9:31 AM

I use auto incrementing IDs for internal use (server and joins) and have a nanoid which is used by users

Original message was deleted

B

berniesumption•6/7/24, 9:31 AM

Yes ULIDs are great - provided that you don't mind leaking the creation time of every entity that you expose the ID of. They look nicer too

Also, I like to prefix my IDs with a short version of the table name, e.g. an employee might be

emp01FHZXHK8PTP9FVK99Z66GXQTX

emp01FHZXHK8PTP9FVK99Z66GXQTX

. I took that idea from Stripe, it makes it so much easier to debug when you have random IDs being passed around.

Jjepcd Hi, is there a limit on the number of statements in a batch call?

M

Max (@rozenmd)OP•6/7/24, 9:55 AM

how ever many queries you can fit before running out of memory

M

Max (@rozenmd)OP•6/7/24, 9:56 AM

I've seen 100k queries in a batch

Jjepcd Hi, is there a limit on the number of statements in a batch call?

N

notjoemartinez•6/8/24, 7:21 AM

The docs are a bit vague on this. I've done about 30k at once, the limit was that the query needs to run in under 30 seconds and I accomplished this by removing some triggers that were slowing it down. I think you still need to consider the number of bindings depending on if they are counted within the batch call. The upper limit for bindings is "approximately" 25 million.

Nnotjoemartinez The docs are a bit vague on this. I've done about 30k at once, the limit was tha...

H

Hello, I’m Allie!•6/8/24, 7:24 AM

As you noted, the binding itself doesn’t place any limits on the number of statements, so the only actual limit is however many you can fit in memory, and that they are created before you overrun the CPU time limit

S

Singer•6/8/24, 9:46 AM

There's probably layers to this question but: D1 or supabase

SSinger There's probably layers to this question but: D1 or supabase

H

Hello, I’m Allie!•6/8/24, 9:51 AM

How big is your app? What kind of data are you storing? How many reads/writes are you doing?

HHello, I’m Allie!How big is your app? What kind of data are you storing? How many reads/writes ar...

S

Singer•6/8/24, 9:58 AM

I'm very new to backend developement and I'm taking things as they come. I'm not sure how big the app is going to get, but I need tables for users, weather data, news api data, events(id,date,actors involved, description, location, image blobs....)

I want to use workers AI which is why I was leaning towards d1 for better integration but I read somewhere that sqlite isn't great for handling lots of data. Again I'm not sure how big this thing can get and I'm fairly new to this realm . A tl;dr or any resources that I can use to improve my knowledge would be great

SSinger I'm very new to backend developement and I'm taking things as they come. I'm not...

H

Hello, I’m Allie!•6/8/24, 10:10 AM

D1 should be fine? Though for larger datasets, I would probably go with Supabase

SSinger I'm very new to backend developement and I'm taking things as they come. I'm not...

M

maj•6/8/24, 12:08 PM

Whatever "handling lots of data" means. Are you talking about millions of records or more? I'm working on an application which has users with > 1M records in a single table, with many relations to other tables. And it's working perfectly fine on a regular Windows PC using SQLite. I'd expect d1 to perform even better.

M

Michał Wróblewski•6/8/24, 1:08 PM

will it be ever possible to do ATTACH DATABASE on D1? It would be great to split some DBs but be able to query them together

HHello, I’m Allie!D1 should be fine? Though for larger datasets, I would probably go with Supabase

S

Singer•6/8/24, 4:09 PM

Thanks, just don't want to get to a point in the near future where I regret going with d1 or sqlite but I don't think I'd reach 1m anytime soon so that's great. Thanks again for the clarity @maj @Hello, I’m Allie!

I

Iaci•6/8/24, 9:56 PM

hi all, i'm developing a worker that has access to D1 databases through D1 database bindings (set as variables under D1 Database Bindings). how am i able to reach those databases when i'm developing locally? using queries like this: {results} = await env.IRADB.prepare(<here goes the query>).bind(<binds>).run();

M

Murder Chicken•6/8/24, 9:58 PM

Is it possible to request an increase in the column limit of 100? If so, what's the best route to do that on the Worker Paid plan?

M

Murder Chicken•6/8/24, 10:03 PM

Never mind, found the limit increase form!

I mean, we'd be running the additional SQL on our side if we added it

Similar Threads

Similar Threads

Similar Threads