Get Started with Drizzle and SingleStore in existing project
This guide assumes familiarity with:
- dotenv - package for managing environment variables - read here
- tsx - package for running TypeScript files - read here
- mysql2 - package for querying your SingleStore database - read here
Basic file structure
This is the basic file structure of the project. In the src/db directory, we have table definition in schema.ts. In drizzle folder there are sql migration file and snapshots.
π¦ <project root>
β π drizzle
β π src
β β π db
β β β π schema.ts
β β π index.ts
β π .env
β π drizzle.config.ts
β π package.json
β π tsconfig.json
Step 1 - Install the mysql2 package
npm i drizzle-orm mysql2 dotenv
npm i -D drizzle-kit tsx
yarn add drizzle-orm mysql2 dotenv
yarn add -D drizzle-kit tsx
pnpm add drizzle-orm mysql2 dotenv
pnpm add -D drizzle-kit tsx
bun add drizzle-orm mysql2 dotenv
bun add -D drizzle-kit tsx
Step 2 - Setup connection variables
Create a .env file in the root of your project and add your database connection variable:
Step 3 - Setup Drizzle config file
Drizzle config - a configuration file that is used by Drizzle Kit and contains all the information about your database connection, migration folder and schema files.
Create a drizzle.config.ts file in the root of your project and add the following content:
import 'dotenv/config';
import { defineConfig } from 'drizzle-kit';
export default defineConfig({
out: './drizzle',
schema: './src/db/schema.ts',
dialect: 'singlestore',
dbCredentials: {
url: process.env.DATABASE_URL!,
},
});
Step 4 - Introspect your database
Drizzle Kit provides a CLI command to introspect your database and generate a schema file with migrations. The schema file contains all the information about your database tables, columns, relations, and indices.
For example, you have such table in your database:
CREATE TABLE `users_table` (
`id` int NOT NULL,
`name` varchar(255) NOT NULL,
`age` int NOT NULL,
`email` varchar(255) NOT NULL,
CONSTRAINT `users_table_id` PRIMARY KEY(`id`),
CONSTRAINT `users_table_email_unique` UNIQUE(`email`)
);
Pull your database schema:
npx drizzle-kit pull --init
The result of introspection will be a schema.ts file and meta folder with snapshots of your database schema
Here is an example of the generated schema.ts file:
// table schema generated by introspection
import {
singlestoreTable,
singlestoreSchema,
AnySingleStoreColumn,
primaryKey,
unique,
varchar,
int,
} from 'drizzle-orm/singlestore-core';
import { sql } from 'drizzle-orm';
export const usersTable = singlestoreTable(
'users_table',
{
id: int().notNull(),
name: varchar({ length: 255 }).notNull(),
age: int().notNull(),
email: varchar({ length: 255 }).notNull(),
},
(table) => [
primaryKey({ columns: [table.id], name: 'users_table_id' }),
unique('id').on(table.id),
unique('users_table_email_unique').on(table.email),
],
);
Learn more about introspection in the documentation.
Step 5 - Transfer code to your actual schema file
We recommend transferring the generated code from drizzle/schema.ts and drizzle/relations.ts to the actual schema file. In this guide we transferred code to src/db/schema.ts. Generated files for schema and relations can be deleted. This way you can manage your schema in a more structured way.
β π drizzle
β β π 20242409125510_premium_mister_fear
β β β π snapshot.json
β β β π migration.sql
β β π relations.ts βββββββββ
β β π schema.ts ββββββββββββ€
β π src β
β β π db β
β β β π relations.ts <ββββββ€
β β β π schema.ts <βββββββββ
β β π index.ts
β β¦
Step 6 - Connect Drizzle ORM to the database
Create a index.ts file in the src/db directory and initialize the connection:
mysql2
mysql2 with config
your mysql2 driver
import 'dotenv/config';
import { drizzle } from "drizzle-orm/singlestore";
const db = drizzle(process.env.DATABASE_URL);
import 'dotenv/config';
import { drizzle } from "drizzle-orm/singlestore";
// You can specify any property from the mysql2 connection options
const db = drizzle({ connection: { uri: process.env.DATABASE_URL }});
import 'dotenv/config';
import { drizzle } from "drizzle-orm/singlestore";
import mysql from "mysql2/promise";
const poolConnection = mysql.createPool({
host: "host",
user: "user",
database: "database",
});
const db = drizzle({ client: poolConnection });
// or if you need client connection
async function main() {
const connection = await mysql.createConnection({
host: "host",
user: "user",
database: "database",
});
const db = drizzle({ client: connection });
}
main();
IMPORTANT
For the built in migrate function with DDL migrations we and drivers strongly encourage you to use single client connection.
For querying purposes feel free to use either client or pool based on your business demands.
Step 7 - Query the database
Letβs update the src/index.ts file with queries to create, read, update, and delete users
import 'dotenv/config';
import { drizzle } from 'drizzle-orm/singlestore';
import { eq } from 'drizzle-orm';
import { usersTable } from './db/schema';
const db = drizzle(process.env.DATABASE_URL!);
async function main() {
const user: typeof usersTable.$inferInsert = {
name: 'John',
age: 30,
email: 'john@example.com',
};
await db.insert(usersTable).values(user);
console.log('New user created!')
const users = await db.select().from(usersTable);
console.log('Getting all users from the database: ', users)
/*
const users: {
id: number;
name: string;
age: number;
email: string;
}[]
*/
await db
.update(usersTable)
.set({
age: 31,
})
.where(eq(usersTable.email, user.email));
console.log('User info updated!')
await db.delete(usersTable).where(eq(usersTable.email, user.email));
console.log('User deleted!')
}
main();
Step 8 - Run index.ts file
To run any TypeScript files, you have several options, but letβs stick with one: using tsx
Youβve already installed tsx, so we can run our queries now
Run index.ts script
npx tsx src/index.ts
yarn tsx src/index.ts
pnpm tsx src/index.ts
bunx tsx src/index.ts
tips
We suggest using bun to run TypeScript files. With bun, such scripts can be executed without issues or additional settings, regardless of whether your project is configured with CommonJS (CJS), ECMAScript Modules (ESM), or any other module format. To run a script with bun, use the following command:
bun src/index.ts
If you donβt have bun installed, check the Bun installation docs
Step 9 - Update your table schema (optional)
If you want to update your table schema, you can do it in the schema.ts file. For example, letβs add a new column phone to the users_table:
import {
singlestoreTable,
singlestoreSchema,
AnySingleStoreColumn,
primaryKey,
unique,
varchar,
int,
} from 'drizzle-orm/singlestore-core';
import { sql } from 'drizzle-orm';
export const usersTable = singlestoreTable(
'users_table',
{
id: int().notNull(),
name: varchar({ length: 255 }).notNull(),
age: int().notNull(),
email: varchar({ length: 255 }).notNull(),
phone: varchar({ length: 255 }),
},
(table) => [
primaryKey({ columns: [table.id], name: 'users_table_id' }),
unique('id').on(table.id),
unique('users_table_email_unique').on(table.email),
],
);
Step 10 - Applying changes to the database (optional)
You can directly apply changes to your database using the drizzle-kit push command. This is a convenient method for quickly testing new schema designs or modifications in a local development environment, allowing for rapid iterations without the need to manage migration files:
npx drizzle-kit push
Read more about the push command in documentation.
Tips
Alternatively, you can generate migrations using the drizzle-kit generate command and then apply them using the drizzle-kit migrate command:
Generate migrations:
npx drizzle-kit generate
Apply migrations:
npx drizzle-kit migrate
Read more about migration process in documentation.
Step 11 - Query the database with a new field (optional)
import 'dotenv/config';
import { drizzle } from 'drizzle-orm/singlestore';
import { eq } from 'drizzle-orm';
import { usersTable } from './db/schema';
const db = drizzle(process.env.DATABASE_URL!);
async function main() {
const user: typeof usersTable.$inferInsert = {
name: 'John',
age: 30,
email: 'john@example.com',
phone: '123-456-7890',
};
await db.insert(usersTable).values(user);
console.log('New user created!')
const users = await db.select().from(usersTable);
console.log('Getting all users from the database: ', users)
/*
const users: {
id: number;
name: string;
age: number;
email: string;
phone: string | null;
}[]
*/
await db
.update(usersTable)
.set({
age: 31,
})
.where(eq(usersTable.email, user.email));
console.log('User info updated!')
await db.delete(usersTable).where(eq(usersTable.email, user.email));
console.log('User deleted!')
}
main();