minato

import Database from 'minato'; import MySQLDriver from '@minatojs/driver-mysql'; import type { Context } from 'cordis'; // Optional, if using Cordis interface User { id: number; name: string; age: number; email?: string; } async function runMinatoExample() { // For Cordis integration, you might pass a Context, otherwise, it's optional. // const ctx = new Context(); // const database = new Database(ctx); const database = new Database(); // Define the schema for the 'user' collection/table database.extend('user', { id: 'unsigned', // Auto-incrementing primary key name: 'string', age: 'integer', email: { type: 'string', nullable: true, unique: true }, }, { primary: 'id', autoInc: true, }); // Connect to the database try { await database.connect(MySQLDriver, { host: 'localhost', port: 3306, user: 'root', password: process.env.DB_PASSWORD ?? '', // Use environment variable for sensitive info database: 'minato_test_db', }); console.log('Successfully connected to MySQL database.'); // Basic CRUD operations // Create const newUser = await database.create('user', { name: 'Alice', age: 30, email: 'alice@example.com', }); console.log('Created user:', newUser); // Find const users = await database.get('user', { age: { $gt: 25 } }); console.log('Users older than 25:', users); // Update await database.set('user', { id: newUser.id }, { age: 31 }); const updatedUser = await database.get('user', { id: newUser.id }); console.log('Updated user:', updatedUser[0]); // Delete await database.remove('user', { id: newUser.id }); console.log('Deleted user with ID:', newUser.id); } catch (error) { console.error('Database operation failed:', error); } finally { await database.disconnect(); console.log('Disconnected from database.'); } } runMinatoExample();