const mysql = require('mysql2/promise');

const pool = mysql.createPool({
  host:            process.env.DB_HOST || 'localhost',
  port:            parseInt(process.env.DB_PORT) || 3306,
  database:        process.env.DB_NAME,
  user:            process.env.DB_USER,
  password:        process.env.DB_PASS,
  waitForConnections: true,
  connectionLimit: 10,
  queueLimit:      0,
  charset:         'utf8mb4',
});

// Hilfsfunktion für einfachere Abfragen
pool.query = async (sql, params) => {
  const [rows] = await pool.execute(sql, params || []);
  return rows;
};

module.exports = pool;