Hey forgive my innocence. This is my first time with cloudflare. I am trying to work with nextjs

Sshrihari Hey forgive my innocence. This is my first time with cloudflare. I am trying ...

M

Have you worked through https://developers.cloudflare.com/pages/framework-guides/deploy-a-nextjs-site/

?

Deploy a Next.js site · Cloudflare Pages docs

Next.js is an open-source React framework for creating websites and applications. In this guide, you will create a new Next.js application and deploy …

Sshrihari Hey forgive my innocence. This is my first time with cloudflare. I am trying ...

M

Matt Silverlock•12/23/23, 3:48 PM

If you can show your code - specifically how you are passing in your bindings - https://developers.cloudflare.com/pages/framework-guides/deploy-a-nextjs-site/#use-bindings-in-your-nextjs-application

then it will help.

Deploy a Next.js site · Cloudflare Pages docs

Next.js is an open-source React framework for creating websites and applications. In this guide, you will create a new Next.js application and deploy …

MMatt Silverlock If you can show your code - specifically how you are passing in your bindings - ...

S

shrihariOP•12/23/23, 3:53 PM

hey Matt I just figured out that my binding name was wrong. it works now . sorry!

A

Ashley•12/23/23, 4:24 PM

When running a migration using a

wrangler.toml

wrangler.toml

file in a Pages project, and if I have a local DB, a preview DB and a production DB (all three are different)... is the best way to simply update

wrangler.toml

wrangler.toml

to reference the different DBs each time?

e.g. point it to

my-preview-db

my-preview-db

my-preview-db

my-preview-db with ID

, run the migration. Update it to

my-production-db

my-production-db

my-production-db

my-production-db with ID

456

456, run the migration again, or is there a better way?

I know there's the

preview_database_id

preview_database_id

preview_database_id

preview_database_id field... but the docs say to set that to

DB

DB

DB

DB for local development, so presumably I can't use that? (or I can... but then local wouldn't work

)

Original message was deleted

I

Isaac McFadyen•12/23/23, 4:36 PM

There's a rate limit of 1200 requests per 5 minutes on the API. https://developers.cloudflare.com/fundamentals/api/reference/limits/

Original message was deleted

I

Isaac McFadyen•12/23/23, 4:49 PM

That would probably also work, yes.

NNico Something like account restrictions for example. So the DB can only be accessed ...

I

Isaac McFadyen•12/23/23, 4:49 PM

Nope, that's not the case. Your database ID is locked to your account.

I

Isaac McFadyen•12/23/23, 4:49 PM

If I get your DB ID, I can't bind to your DB or access it via the API.

NNico Ah perfect. Is their any documentation about this or other security aspects. Bec...

I

Isaac McFadyen•12/23/23, 4:52 PM

It's not really D1 specific so I'm guessing that's why it's not in those docs. All of the bindings that can be attached to Workers are locked to the account they were created in, and as celestial said the API is locked to your API key

G

Gagan Suie•12/25/23, 4:23 AM

greetings! is there a way to import JSON collections from mongodb into D1?

P

Paolo•12/25/23, 5:11 AM

Hi! Has anyone used Waterline or any Active Record ORM with D1? Can you suggest anything that works?

D

divby0•12/25/23, 10:52 AM

I just downloaded an alpha DB backup, dumped into a

.sql

.sql

file and want to execute it on a beta DB now. The error I get is

wrangler d1 execute rank-hub-beta --file backup.sql
🌀 Mapping SQL input into an array of statements
🌀 Parsing 35944 statements
🌀 We are sending 4 batch(es) to D1 (limited to 10000 statements per batch. Use --batch-size to override.)
✔ ⚠️  Too much SQL to send at once, this execution will be sent as 4 batches.
ℹ️  Each batch is sent individually and may leave your DB in an unexpected state if a later batch fails.
⚠️  Make sure you have a recent backup. Ok to proceed? … yes
🌀 Let's go
🌀 Executing on remote database rank-hub-beta (24b71fed-ab4c-44b4-94fb-c7eeb5c42190):
🌀 To execute on your local development database, pass the --local flag to 'wrangler d1 execute'
  PRAGMA foreign_keys=OFF; CREATE TABLE d1_kv (key TEXT PRIMARY KEY, val...

✘ [ERROR] A request to the Cloudflare API (/accounts/8f4214243c247a1a0bb46647a55d5614/d1/database/24b71fed-ab4c-44b4-94fb-c7eeb5c42190/query) failed.

  no such table: main.users [code: 7500]
  
  If you think this is a bug, please open an issue at:
  https://github.com/cloudflare/workers-sdk/issues/new/choose

wrangler d1 execute rank-hub-beta --file backup.sql
🌀 Mapping SQL input into an array of statements
🌀 Parsing 35944 statements
🌀 We are sending 4 batch(es) to D1 (limited to 10000 statements per batch. Use --batch-size to override.)
✔ ⚠️  Too much SQL to send at once, this execution will be sent as 4 batches.
ℹ️  Each batch is sent individually and may leave your DB in an unexpected state if a later batch fails.
⚠️  Make sure you have a recent backup. Ok to proceed? … yes
🌀 Let's go
🌀 Executing on remote database rank-hub-beta (24b71fed-ab4c-44b4-94fb-c7eeb5c42190):
🌀 To execute on your local development database, pass the --local flag to 'wrangler d1 execute'
  PRAGMA foreign_keys=OFF; CREATE TABLE d1_kv (key TEXT PRIMARY KEY, val...

✘ [ERROR] A request to the Cloudflare API (/accounts/8f4214243c247a1a0bb46647a55d5614/d1/database/24b71fed-ab4c-44b4-94fb-c7eeb5c42190/query) failed.

  no such table: main.users [code: 7500]
  
  If you think this is a bug, please open an issue at:
  https://github.com/cloudflare/workers-sdk/issues/new/choose

wrangler d1 execute rank-hub-beta --file backup.sql
🌀 Mapping SQL input into an array of statements
🌀 Parsing 35944 statements
🌀 We are sending 4 batch(es) to D1 (limited to 10000 statements per batch. Use --batch-size to override.)
✔ ⚠️  Too much SQL to send at once, this execution will be sent as 4 batches.
ℹ️  Each batch is sent individually and may leave your DB in an unexpected state if a later batch fails.
⚠️  Make sure you have a recent backup. Ok to proceed? … yes
🌀 Let's go
🌀 Executing on remote database rank-hub-beta (24b71fed-ab4c-44b4-94fb-c7eeb5c42190):
🌀 To execute on your local development database, pass the --local flag to 'wrangler d1 execute'
  PRAGMA foreign_keys=OFF; CREATE TABLE d1_kv (key TEXT PRIMARY KEY, val...

✘ [ERROR] A request to the Cloudflare API (/accounts/8f4214243c247a1a0bb46647a55d5614/d1/database/24b71fed-ab4c-44b4-94fb-c7eeb5c42190/query) failed.

  no such table: main.users [code: 7500]
  
  If you think this is a bug, please open an issue at:
  https://github.com/cloudflare/workers-sdk/issues/new/choose

wrangler d1 execute rank-hub-beta --file backup.sql
🌀 Mapping SQL input into an array of statements
🌀 Parsing 35944 statements
🌀 We are sending 4 batch(es) to D1 (limited to 10000 statements per batch. Use --batch-size to override.)
✔ ⚠️  Too much SQL to send at once, this execution will be sent as 4 batches.
ℹ️  Each batch is sent individually and may leave your DB in an unexpected state if a later batch fails.
⚠️  Make sure you have a recent backup. Ok to proceed? … yes
🌀 Let's go
🌀 Executing on remote database rank-hub-beta (24b71fed-ab4c-44b4-94fb-c7eeb5c42190):
🌀 To execute on your local development database, pass the --local flag to 'wrangler d1 execute'
  PRAGMA foreign_keys=OFF; CREATE TABLE d1_kv (key TEXT PRIMARY KEY, val...

✘ [ERROR] A request to the Cloudflare API (/accounts/8f4214243c247a1a0bb46647a55d5614/d1/database/24b71fed-ab4c-44b4-94fb-c7eeb5c42190/query) failed.

  no such table: main.users [code: 7500]
  
  If you think this is a bug, please open an issue at:
  https://github.com/cloudflare/workers-sdk/issues/new/choose

I scanned the

backup.sql

backup.sql

backup.sql

backup.sql with vim for "main.users" but couldn't find anything.

Ddivby0 I just downloaded an alpha DB backup, dumped into a `.sql` file and want to exec...

P

Paolo•12/25/23, 12:37 PM

What about users? Do you have the create table statements?

D

divby0•12/25/23, 12:39 PM

Yes, I found them. I think this was a different issue somehow.

.drop

.drop

.drop

.drop-ing the users table without everythign else worked fine. I just imported the most important tables on my own

J

jahir9991•12/26/23, 1:42 AM

Can i write db functin in d1?

S

shrihariOP•12/26/23, 9:27 AM

is there any future plans to allow d1 to connect to dbeaver or other db tools

Sshrihari is there any future plans to allow d1 to connect to dbeaver or other db tools

M

Matt Silverlock•12/26/23, 5:01 PM

That would depend on those tools supporting D1.

MMatt Silverlock That would depend on those tools supporting D1.

S

shrihariOP•12/26/23, 5:03 PM

Oh I thought of like getting an connection string and using that in sqllite connector in dbeaver .

Sshrihari Oh I thought of like getting an connection string and using that in sqllite conn...

M

Matt Silverlock•12/26/23, 5:05 PM

"SQLite" in the way those tools support it is file-based: there's not a standard SQLite HTTP protocol of any kind. Those tools would need to support D1's REST API.

C

Chris•12/27/23, 1:27 AM

I'm wondering if there will be any ways to limit access to a live database, especially from wrangler?

For example, I just executed this command:

npx wrangler d1 execute db --command 'delete from user where id > 123;' --local

npx wrangler d1 execute db --command 'delete from user where id > 123;' --local

npx wrangler d1 execute db --command 'delete from user where id > 123;' --local

npx wrangler d1 execute db --command 'delete from user where id > 123;' --local

But I originally typo'd it as this, which would have run against the remote database (since that's quite scarily the default):

npx wrangler d1 execute db --command 'delete from user where id > 123'; --local

npx wrangler d1 execute db --command 'delete from user where id > 123'; --local

npx wrangler d1 execute db --command 'delete from user where id > 123'; --local

npx wrangler d1 execute db --command 'delete from user where id > 123'; --local

While we have Time Travel, I wouldn't really want a developer to take out production by mistake due to a single character transposition…

R

roccho•12/27/23, 4:07 AM

D1 cannot a certain column despite that this column already tested.
test'user.register' has already been passed.
but when 'validate inserted ...' test, vitest alert us.

 FAIL  packages/economy/src/route/index.query.test.ts > queries > after ddl > user.register > validate inserted user.register
Error: D1_ERROR: no such column: email

 FAIL  packages/economy/src/route/index.query.test.ts > queries > after ddl > user.register > validate inserted user.register
Error: D1_ERROR: no such column: email

 FAIL  packages/economy/src/route/index.query.test.ts > queries > after ddl > user.register > validate inserted user.register
Error: D1_ERROR: no such column: email

 FAIL  packages/economy/src/route/index.query.test.ts > queries > after ddl > user.register > validate inserted user.register
Error: D1_ERROR: no such column: email

Anything wrong?

  describe('after ddl', () => {
    describe('user.register', async () => {
      const { results } = await d1db.prepare('PRAGMA table_info(user);').all()
      const columnNames = results.map((result) => result.name)
      test('user.register column has been created', async () => {
        console.debug('columnNames', columnNames)
        expect(columnNames).toContain('email')
        expect(columnNames).toContain('user_id')
        expect(columnNames).toContain('user_name')
        expect(columnNames).toContain('user_role')
      })

      test('validate inserted user.register', async () => {
        const query = endpoints.user.register.query.insert_user({
          email: 'email',
          user_id: 'user_id',
          user_name: 'user_name',
          user_role: 'user_role',
        })
        await d1db.prepare(query).run()
        const { results } = await d1db.prepare('SELECT * FROM user;').all()

  describe('after ddl', () => {
    describe('user.register', async () => {
      const { results } = await d1db.prepare('PRAGMA table_info(user);').all()
      const columnNames = results.map((result) => result.name)
      test('user.register column has been created', async () => {
        console.debug('columnNames', columnNames)
        expect(columnNames).toContain('email')
        expect(columnNames).toContain('user_id')
        expect(columnNames).toContain('user_name')
        expect(columnNames).toContain('user_role')
      })

      test('validate inserted user.register', async () => {
        const query = endpoints.user.register.query.insert_user({
          email: 'email',
          user_id: 'user_id',
          user_name: 'user_name',
          user_role: 'user_role',
        })
        await d1db.prepare(query).run()
        const { results } = await d1db.prepare('SELECT * FROM user;').all()

  describe('after ddl', () => {
    describe('user.register', async () => {
      const { results } = await d1db.prepare('PRAGMA table_info(user);').all()
      const columnNames = results.map((result) => result.name)
      test('user.register column has been created', async () => {
        console.debug('columnNames', columnNames)
        expect(columnNames).toContain('email')
        expect(columnNames).toContain('user_id')
        expect(columnNames).toContain('user_name')
        expect(columnNames).toContain('user_role')
      })

      test('validate inserted user.register', async () => {
        const query = endpoints.user.register.query.insert_user({
          email: 'email',
          user_id: 'user_id',
          user_name: 'user_name',
          user_role: 'user_role',
        })
        await d1db.prepare(query).run()
        const { results } = await d1db.prepare('SELECT * FROM user;').all()

  describe('after ddl', () => {
    describe('user.register', async () => {
      const { results } = await d1db.prepare('PRAGMA table_info(user);').all()
      const columnNames = results.map((result) => result.name)
      test('user.register column has been created', async () => {
        console.debug('columnNames', columnNames)
        expect(columnNames).toContain('email')
        expect(columnNames).toContain('user_id')
        expect(columnNames).toContain('user_name')
        expect(columnNames).toContain('user_role')
      })

      test('validate inserted user.register', async () => {
        const query = endpoints.user.register.query.insert_user({
          email: 'email',
          user_id: 'user_id',
          user_name: 'user_name',
          user_role: 'user_role',
        })
        await d1db.prepare(query).run()
        const { results } = await d1db.prepare('SELECT * FROM user;').all()

Rroccho D1 cannot a certain column despite that this column already tested. test'user.re...

M

Matt Silverlock•12/27/23, 11:41 AM

Where do you create the table? What is the output of

PRAGMA table_info(user)

PRAGMA table_info(user)

PRAGMA table_info(user)

PRAGMA table_info(user) from your test?

G

GuillaumeLakano•12/27/23, 3:38 PM

Hi! How can we known in "wrangler d1 execute --file data.sql" which SQL line make an error please?

Our file contains many thousand of SQL lines, and SQLite return an error without printing the last SQL query executed, neither the line in the file, this could be really useful to save time

Original message was deleted

G

GuillaumeLakano•12/27/23, 5:43 PM

it's a temporary workaround, depending if we can install sqlite3 of the exact same version to mitigate problems. But this will be more convenient to show the file line + query when there is an error in wrangler

G

GuillaumeLakano•12/27/23, 6:05 PM

it's with --local already

K

kian•12/27/23, 6:05 PM

If SQLite has a character number to associate with the error then it’ll be in the error - if not then Wrangler won’t be able to correlate it to a specific line/statement anyways.

Kkian If SQLite has a character number to associate with the error then it’ll be in th...

G

GuillaumeLakano•12/27/23, 6:07 PM

In this case, this was for a foreign key constraint, but I have no information about which foreign key is concerned, neither the line in the SQL file, neither the query... it's hard to debug ^^

K

kian•12/27/23, 6:12 PM

What error does the SQLite CLI give you?

G

GuillaumeLakano•12/27/23, 6:14 PM

this was something similar to:

[ERROR] Foreign key constraint error

that's all

G

GuillaumeLakano•12/27/23, 6:15 PM

I can try to make it happen again if you want the exact sentence?

Kkian What error does the SQLite CLI give you?

G

GuillaumeLakano•12/27/23, 6:20 PM

npx wrangler --persist-to ../../../.wrangler d1 execute content --local --file ./sql/test.sql
Mapping SQL input into an array of statements
Executing on local database content (00000000-0000-0000-0007-000000000000) from ../../../.wrangler/v3/d1:

✘ [ERROR] FOREIGN KEY constraint failed

If you think this is a bug then please create an issue at https://github.com/cloudflare/workers-sdk/issues/new/choose
? Would you like to report this error to Cloudflare? › (Y/n)

Original message was deleted

G

GuillaumeLakano•12/27/23, 6:57 PM

interesting! I'll take a look, thank you for your help!

MMatt Silverlock Where do you create the table? What is the output of `PRAGMA table_info(user)` f...

R

roccho•12/27/23, 9:28 PM

Thanks reply.

where: d1 instance named "d1db" using miniflare
output: 4 created columns like test as above

Rroccho Thanks reply. where: d1 instance named "d1db" using miniflare output: 4 created...

R

roccho•12/27/23, 10:15 PM

About d1db

describe('queries', async () => {
  const mf = new Miniflare({
    name: 'main',
    modules: true,
    script: `
                    export default {
                    async fetch(request, env, ctx){
                        return new Response('Hello World!');
                    },};
                    `,
    d1Databases: ['D1'],
  })

  const d1db = await mf.getD1Database('D1')

  // exec ddl...


  test('assert table', async () => {
    const { results } = await d1db.prepare('SELECT * FROM sqlite_master;').all()
    const tableNames = results.map((result) => result.name)
    console.debug('tableNames', tableNames)
    expect(tableNames).toContain('user')
    expect(tableNames).toContain('account')
  }

// output:
// tableNames [ '_cf_KV', 'user', 'account' ]

describe('queries', async () => {
  const mf = new Miniflare({
    name: 'main',
    modules: true,
    script: `
                    export default {
                    async fetch(request, env, ctx){
                        return new Response('Hello World!');
                    },};
                    `,
    d1Databases: ['D1'],
  })

  const d1db = await mf.getD1Database('D1')

  // exec ddl...


  test('assert table', async () => {
    const { results } = await d1db.prepare('SELECT * FROM sqlite_master;').all()
    const tableNames = results.map((result) => result.name)
    console.debug('tableNames', tableNames)
    expect(tableNames).toContain('user')
    expect(tableNames).toContain('account')
  }

// output:
// tableNames [ '_cf_KV', 'user', 'account' ]

describe('queries', async () => {
  const mf = new Miniflare({
    name: 'main',
    modules: true,
    script: `
                    export default {
                    async fetch(request, env, ctx){
                        return new Response('Hello World!');
                    },};
                    `,
    d1Databases: ['D1'],
  })

  const d1db = await mf.getD1Database('D1')

  // exec ddl...


  test('assert table', async () => {
    const { results } = await d1db.prepare('SELECT * FROM sqlite_master;').all()
    const tableNames = results.map((result) => result.name)
    console.debug('tableNames', tableNames)
    expect(tableNames).toContain('user')
    expect(tableNames).toContain('account')
  }

// output:
// tableNames [ '_cf_KV', 'user', 'account' ]

describe('queries', async () => {
  const mf = new Miniflare({
    name: 'main',
    modules: true,
    script: `
                    export default {
                    async fetch(request, env, ctx){
                        return new Response('Hello World!');
                    },};
                    `,
    d1Databases: ['D1'],
  })

  const d1db = await mf.getD1Database('D1')

  // exec ddl...


  test('assert table', async () => {
    const { results } = await d1db.prepare('SELECT * FROM sqlite_master;').all()
    const tableNames = results.map((result) => result.name)
    console.debug('tableNames', tableNames)
    expect(tableNames).toContain('user')
    expect(tableNames).toContain('account')
  }

// output:
// tableNames [ '_cf_KV', 'user', 'account' ]

Rroccho About d1db ``` describe('queries', async () => { const mf = new Miniflare({ ...

R

roccho•12/27/23, 10:16 PM

About columns

// output
// columnNames [ 'user_id', 'user_name', 'user_role', 'email', 'other_info' ]

// output
// columnNames [ 'user_id', 'user_name', 'user_role', 'email', 'other_info' ]

// output
// columnNames [ 'user_id', 'user_name', 'user_role', 'email', 'other_info' ]

// output
// columnNames [ 'user_id', 'user_name', 'user_role', 'email', 'other_info' ]

M

MUTE.CB•12/27/23, 11:22 PM

Hello, I have a question about using D1, an SQL database, in a project hosted on Vercel. Can D1 be integrated with Vercel for web applications? Also, how would one set up Prisma with D1 in this environment? Any insights or guidance on this setup would be greatly appreciated.

A

AsyncBanana•12/28/23, 4:18 AM

Is there any way to use per-tenant dbs with d1 without using workers platforms? I am not sure how to dynamically bind d1 dbs to enable this without workers platforms.

MMUTE.CB Hello, I have a question about using D1, an SQL database, in a project hosted on...

J

jacky•12/28/23, 6:31 AM

you can absolutely integrate d1 into Vercel, just write a worker as an API to work with.

J

jacky•12/28/23, 6:35 AM

// d1.js
export default async function (ctx) {
  let db = ctx.env.DB
  let body

  try {
    body = await ctx.req.json()
  } catch (e) {
    return ctx.json({
      status: 'error',
      message: 'Invalid json body'
    }, 400)
  }

  let api_key = ctx.req.header('x-api-key')

  if (!api_key) {
    return ctx.json({
      status: 'error',
      message: 'No api key provided'
    }, 400)
  }

  if (api_key !== ctx.env.D1_API_KEY) {
    return ctx.json({
      status: 'error',
      message: 'Invalid api key'
    }, 401)
  }

  let stmt = body.stmt
  let binds = body.binds

  if (!stmt) {
    return ctx.json({
      status: 'error',
      message: 'No statement provided'
    }, 400)
  }

  let action

  try {
    let db_stmt

    if (binds && binds.length) {
      db_stmt = db.prepare(stmt).bind(...binds)
    } else {
      db_stmt = db.prepare(stmt)
    }

    action = await db_stmt.run()
  } catch (e) {
    let message = e.message || e.toString()

    return ctx.json({
      status: 'error',
      message: message
    }, 502)
  }

  if (!action.success) {
    return ctx.json({
      status: 'error',
      message: 'db fetch error'
    }, 502)
  }

  return ctx.json({
    status: 'ok',
    data: action.results
  })
}

// d1.js
export default async function (ctx) {
  let db = ctx.env.DB
  let body

  try {
    body = await ctx.req.json()
  } catch (e) {
    return ctx.json({
      status: 'error',
      message: 'Invalid json body'
    }, 400)
  }

  let api_key = ctx.req.header('x-api-key')

  if (!api_key) {
    return ctx.json({
      status: 'error',
      message: 'No api key provided'
    }, 400)
  }

  if (api_key !== ctx.env.D1_API_KEY) {
    return ctx.json({
      status: 'error',
      message: 'Invalid api key'
    }, 401)
  }

  let stmt = body.stmt
  let binds = body.binds

  if (!stmt) {
    return ctx.json({
      status: 'error',
      message: 'No statement provided'
    }, 400)
  }

  let action

  try {
    let db_stmt

    if (binds && binds.length) {
      db_stmt = db.prepare(stmt).bind(...binds)
    } else {
      db_stmt = db.prepare(stmt)
    }

    action = await db_stmt.run()
  } catch (e) {
    let message = e.message || e.toString()

    return ctx.json({
      status: 'error',
      message: message
    }, 502)
  }

  if (!action.success) {
    return ctx.json({
      status: 'error',
      message: 'db fetch error'
    }, 502)
  }

  return ctx.json({
    status: 'ok',
    data: action.results
  })
}

// d1.js
export default async function (ctx) {
  let db = ctx.env.DB
  let body

  try {
    body = await ctx.req.json()
  } catch (e) {
    return ctx.json({
      status: 'error',
      message: 'Invalid json body'
    }, 400)
  }

  let api_key = ctx.req.header('x-api-key')

  if (!api_key) {
    return ctx.json({
      status: 'error',
      message: 'No api key provided'
    }, 400)
  }

  if (api_key !== ctx.env.D1_API_KEY) {
    return ctx.json({
      status: 'error',
      message: 'Invalid api key'
    }, 401)
  }

  let stmt = body.stmt
  let binds = body.binds

  if (!stmt) {
    return ctx.json({
      status: 'error',
      message: 'No statement provided'
    }, 400)
  }

  let action

  try {
    let db_stmt

    if (binds && binds.length) {
      db_stmt = db.prepare(stmt).bind(...binds)
    } else {
      db_stmt = db.prepare(stmt)
    }

    action = await db_stmt.run()
  } catch (e) {
    let message = e.message || e.toString()

    return ctx.json({
      status: 'error',
      message: message
    }, 502)
  }

  if (!action.success) {
    return ctx.json({
      status: 'error',
      message: 'db fetch error'
    }, 502)
  }

  return ctx.json({
    status: 'ok',
    data: action.results
  })
}

// d1.js
export default async function (ctx) {
  let db = ctx.env.DB
  let body

  try {
    body = await ctx.req.json()
  } catch (e) {
    return ctx.json({
      status: 'error',
      message: 'Invalid json body'
    }, 400)
  }

  let api_key = ctx.req.header('x-api-key')

  if (!api_key) {
    return ctx.json({
      status: 'error',
      message: 'No api key provided'
    }, 400)
  }

  if (api_key !== ctx.env.D1_API_KEY) {
    return ctx.json({
      status: 'error',
      message: 'Invalid api key'
    }, 401)
  }

  let stmt = body.stmt
  let binds = body.binds

  if (!stmt) {
    return ctx.json({
      status: 'error',
      message: 'No statement provided'
    }, 400)
  }

  let action

  try {
    let db_stmt

    if (binds && binds.length) {
      db_stmt = db.prepare(stmt).bind(...binds)
    } else {
      db_stmt = db.prepare(stmt)
    }

    action = await db_stmt.run()
  } catch (e) {
    let message = e.message || e.toString()

    return ctx.json({
      status: 'error',
      message: message
    }, 502)
  }

  if (!action.success) {
    return ctx.json({
      status: 'error',
      message: 'db fetch error'
    }, 502)
  }

  return ctx.json({
    status: 'ok',
    data: action.results
  })
}

// index.js
import {Hono} from 'hono'
import {cors} from 'hono/cors'
import {logger} from 'hono/logger'

import _d1 from './d1.js'


const app = new Hono()

app.use('*', cors())
app.use('*', logger())

// db
app.post('/d1', _d1)

// catch all
app.get('*', (ctx) => {
  return ctx.text('404 Not Found', 404)
})

export default app

// index.js
import {Hono} from 'hono'
import {cors} from 'hono/cors'
import {logger} from 'hono/logger'

import _d1 from './d1.js'


const app = new Hono()

app.use('*', cors())
app.use('*', logger())

// db
app.post('/d1', _d1)

// catch all
app.get('*', (ctx) => {
  return ctx.text('404 Not Found', 404)
})

export default app

// index.js
import {Hono} from 'hono'
import {cors} from 'hono/cors'
import {logger} from 'hono/logger'

import _d1 from './d1.js'


const app = new Hono()

app.use('*', cors())
app.use('*', logger())

// db
app.post('/d1', _d1)

// catch all
app.get('*', (ctx) => {
  return ctx.text('404 Not Found', 404)
})

export default app

// index.js
import {Hono} from 'hono'
import {cors} from 'hono/cors'
import {logger} from 'hono/logger'

import _d1 from './d1.js'


const app = new Hono()

app.use('*', cors())
app.use('*', logger())

// db
app.post('/d1', _d1)

// catch all
app.get('*', (ctx) => {
  return ctx.text('404 Not Found', 404)
})

export default app

this is my implementation

J

jacky•12/28/23, 6:39 AM

works like a charm