Node.js - sql.connectionString()

Returns the connection string for a SQL database at runtime.

import { sql } from '@nitric/sdk'
const db = sql('my-data')
// Should be called at runtime, such as in a service handler
const connStr = await db.connectionString()

Examples

Return a connection string

import { sql } from '@nitric/sdk'
const db = sql('my-data')
// Should be called at runtime, such as in a service handler
const connStr = await db.connectionString()

Connect with Prisma

import { api, sql } from '@nitric/sdk'
import { PrismaClient } from '@prisma/client'
const mainApi = api('main')
const db = sql('my-data')
let prisma
const getClient = async () => {
// ensure we only create the client once
if (!prisma) {
const connectionString = await db.connectionString()
prisma = new PrismaClient({
datasourceUrl: connectionString,
})
}
return prisma
}
// api demonstrating connecting to prisma and then doing an insert and select
mainApi.post('/users/:name', async (ctx) => {
const { name } = ctx.req.params
const client = await getClient()
await client.user.create({
data: {
name,
email: `${name}@example.com`,
},
})
const createdUser = await client.user.findFirstOrThrow({
where: {
name,
},
})
ctx.res.body = `Created ${name} with ID ${createdUser.id}`
return ctx
})

Connect with Drizzle

import { api, sql } from '@nitric/sdk'
import { drizzle } from 'drizzle-orm/postgres-js'
import * as schema from '../schema'
import postgres from 'postgres'
import { eq } from 'drizzle-orm'
const mainApi = api('main')
const db = sql('my-data')
let drizzleClient
const getClient = async () => {
// ensure we only create the client once
if (!drizzleClient) {
const connectionString = await db.connectionString()
const queryClient = postgres(connectionString)
drizzleClient = drizzle(queryClient, { schema })
}
return drizzleClient
}
// api demonstrating connecting with drizzle and then doing an insert and select
mainApi.post('/users/:name', async (ctx) => {
const { name } = ctx.req.params
const client = await getClient()
await client.insert(schema.users).values({
name,
email: `${name}@example.com`,
})
const createdUser = await client
.select()
.from(schema.users)
.where(eq(schema.users.name, name))
ctx.res.body = `Created ${name} with ID ${createdUser[0].id}`
return ctx
})
Last updated on Dec 19, 2024