mysql2

import mysql from 'mysql2/promise'; import { RowDataPacket, OkPacket, ResultSetHeader } from 'mysql2'; async function runExample() { const pool = mysql.createPool({ host: process.env.DB_HOST ?? 'localhost', user: process.env.DB_USER ?? 'root', password: process.env.DB_PASSWORD ?? 'password', database: process.env.DB_DATABASE ?? 'test_db', waitForConnections: true, connectionLimit: 10, queueLimit: 0 }); try { // Create a table if it doesn't exist await pool.execute<ResultSetHeader>(` CREATE TABLE IF NOT EXISTS users ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255) NOT NULL, email VARCHAR(255) UNIQUE NOT NULL ) `); console.log('Table "users" ensured.'); // Insert a new user using a prepared statement const name = 'Alice'; const email = 'alice@example.com'; const [insertResult] = await pool.execute<OkPacket>( 'INSERT INTO users (name, email) VALUES (?, ?)', [name, email] ); console.log(`Inserted user with ID: ${insertResult.insertId}`); // Select users const [rows] = await pool.execute<RowDataPacket[]>('SELECT id, name, email FROM users WHERE name = ?', [name]); if (rows.length > 0) { console.log('Found users:'); rows.forEach(row => { console.log(`- ID: ${row.id}, Name: ${row.name}, Email: ${row.email}`); }); } else { console.log(`No user found with name: ${name}`); } } catch (error) { console.error('Database operation failed:', error); } finally { // Ensure the pool is closed when done await pool.end(); console.log('Database pool closed.'); } } runExample();