diff --git a/frameworks/JavaScript/ultimate-express/database/mysql.js b/frameworks/JavaScript/ultimate-express/database/mysql.js index 16b3c482083..ca45835631d 100644 --- a/frameworks/JavaScript/ultimate-express/database/mysql.js +++ b/frameworks/JavaScript/ultimate-express/database/mysql.js @@ -4,15 +4,13 @@ import { clientOpts } from '../config.js' const pool = createPool({ ...clientOpts, connectionLimit: cpus().length }) -const execute = (text, values) => pool.execute(text, values || undefined) - -export const fortunes = () => execute('SELECT id, message FROM fortune') +export const fortunes = () => pool.execute('SELECT id, message FROM fortune') export const find = async(id) => { - const arr = await execute('SELECT id, randomNumber AS randomnumber FROM world WHERE id = ?', [id]); + const arr = await pool.execute('SELECT id, randomNumber AS randomnumber FROM world WHERE id = ?', [id]); return arr[0]; } -export const getAllWorlds = () => execute('SELECT id, randomNumber AS randomnumber FROM world') +export const getAllWorlds = () => pool.execute('SELECT id, randomNumber AS randomnumber FROM world') export const bulkUpdate = (worlds) => pool.batch('UPDATE world SET randomNumber = ? WHERE id = ?', worlds.map(world => [world.randomNumber, world.id]).sort((a, b) => (a[1] < b[1]) ? -1 : 1)) \ No newline at end of file diff --git a/frameworks/JavaScript/ultimate-express/database/postgres.js b/frameworks/JavaScript/ultimate-express/database/postgres.js index f16f6cefefd..6846da4d5fe 100644 --- a/frameworks/JavaScript/ultimate-express/database/postgres.js +++ b/frameworks/JavaScript/ultimate-express/database/postgres.js @@ -1,7 +1,7 @@ import postgres from 'postgres' import { clientOpts } from '../config.js' -const sql = postgres({ ...clientOpts, max: 1 }) +const sql = postgres({ ...clientOpts, max: 1, fetch_types: false }) export const fortunes = () => sql`SELECT id, message FROM fortune`