Conexão com banco e início de repository
This commit is contained in:
parent
a746e5b6a9
commit
47a68c4856
|
|
@ -0,0 +1,7 @@
|
||||||
|
PORT=5000
|
||||||
|
|
||||||
|
DB_HOST=
|
||||||
|
DB_PORT=
|
||||||
|
DB_USER=
|
||||||
|
DB_PASSWORD=
|
||||||
|
DB_NAME=
|
||||||
|
|
@ -0,0 +1,19 @@
|
||||||
|
import mysql from "mysql2/promise";
|
||||||
|
import dotenv from "dotenv";
|
||||||
|
|
||||||
|
dotenv.config();
|
||||||
|
|
||||||
|
export const pool = mysql.createPool({
|
||||||
|
host : process.env.DB_HOST,
|
||||||
|
port : process.env.DB_PORT,
|
||||||
|
user: process.env.DB_USER,
|
||||||
|
database: process.env.DB_NAME,
|
||||||
|
password: process.env.DB_PASSWORD,
|
||||||
|
waitForConnections: true,
|
||||||
|
connectionLimit: 10
|
||||||
|
});
|
||||||
|
|
||||||
|
export async function query(sql, params = []){
|
||||||
|
const [rows] = await pool.execute(sql, params);
|
||||||
|
return rows;
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,18 @@
|
||||||
|
import {query} from "../config/database.js";
|
||||||
|
|
||||||
|
export async function findAll() {
|
||||||
|
return query(`select usuario.id, usuario.nome, usuario.email, perfil.nome
|
||||||
|
from usuario inner join perfil on
|
||||||
|
usuario.perfil_id = perfil.id
|
||||||
|
where usuario.ativo = true`)
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function findById(id) {
|
||||||
|
return query(`select usuario.id, usuario.nome, usuario.email, perfil.nome
|
||||||
|
from usuario inner join perfil on
|
||||||
|
usuario.perfil_id = perfil.id
|
||||||
|
where usuario.ativo = true and usuario.id = ?`,
|
||||||
|
[id])
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
Loading…
Reference in New Issue