import { waddler } from "waddler";

const sql = waddler({ dbUrl: "md:?…", min: 1, max: 8 }); // MotherDuck connection URL

// fetches concurrently
const res = await Promise.all([
	sql`select 1`,
	sql`select 2`,
]);

await sql`select * from ${sql.identifier("users")}`;
await sql`select ${sql.identifier("id")} from ${sql.identifier("users")}`;
await sql`select ${sql.identifier(["id", "name", "email"])} from ${sql.identifier("users")}`;

select * from "users";
select "id" from "users";
select "id", "name", "email" from "users";

await sql`insert into "users" ("name") values ${sql.values([["Dan"]])}`;

const values = sql.values([["Dan", "[email protected]", 25]]);
await sql`insert into "users" ("name", "email", "age") values ${values}`;

insert into "users" ("name") values ('Dan');
insert into "users" ("name") values ('Dan', '[email protected]', 25);

const listUsers = async (filter: string | undefined) => {
  const whereClause = filter ? sql.raw(` where ${filter}`) : sql.raw("");
  return sql`select * from "users"${whereClause}`;
}

await listUsers(`"id" = 10`);
await listUsers(`"name" = 'Dan'`);
await listUsers();

select * from "users" where "id" = 10;
select * from "users" where "name" = 'Dan';
select * from "users";

const result = sql`select * from users`.stream();

for await (const row of result) {
  console.log(row);
}

{
  id: 1,
	name: "Alex",
}
{
  id: 2,
	name: "Oleksii",
}

const result = sql`select * from users`.chunked(2);

for await (const chunk of result) {
  console.log(chunk);
}

[
	{
  	id: 1,
		name: "Alex",
	},
	{
	  id: 2,
		name: "Oleksii",
	}
]
…