Skip to main content
Generic abstraction layer
Origen Enlace
VRoxa
  • 3.1k
  • 8
  • 19

EDIT: Hacer una capa de abstracción genérica

// Una función genérica que resuelva diferentes tipos de modelos
const selectBy = <TResult>(table: string, key: string, param: number | string) =>
    new Promise<TResult[]>((resolve, reject) => {
        // Hacemos un string template para construir la query
        pool.query(`SELECT * FROM ${table} WHERE ${key} = ?`, [param],
        (err: any, rows: any, fields: any) => {
            if (err) reject(err); // En caso de error, resolvemos la Promise con error
            resolve(rows as TResult[]); // Si no, resolvemos con el resultado
        });
    });

De este modo podemos reaprovechar la función en diferentes escenarios.

interface Person {
    id: number,
    // ...
}

interface User {
    id: number,
    username: string
    // ...
}

(async () => {
    const [ user ] = await selectBy<User>(`user_table`, `username`, `rosa1`);
    const [ person ] = await selectBy<Person>(`person_table`, `personId`, user.id);

    console.log(user);
    console.log(person);
})();

Una vez con esto, ya se pueden sacar diferentes funciones que ahorren el paso de los parámetros user_table o person_table, por ejemplo.
La lógica interna será compartida, por lo que cualquier cambio se va a aplicar a todas las funciones delegadas, en vez de tener que ir una a una (lo cual es un foco de bugs).

const selectPerson = (id: number) => selectBy<Person>(`person_table`, `personId`, id);
const selectUser = (id: string) => selectBy<User>(`user_table`, `username`, id);

(async () => {
    const [ user ] = await selectUser('rosa1');
    const [ person ] = await selectPerson(user.id);

    console.log(user);
    console.log(person);
})();

Espero que sirva.

Espero que sirva.

EDIT: Hacer una capa de abstracción genérica

// Una función genérica que resuelva diferentes tipos de modelos
const selectBy = <TResult>(table: string, key: string, param: number | string) =>
    new Promise<TResult[]>((resolve, reject) => {
        // Hacemos un string template para construir la query
        pool.query(`SELECT * FROM ${table} WHERE ${key} = ?`, [param],
        (err: any, rows: any, fields: any) => {
            if (err) reject(err); // En caso de error, resolvemos la Promise con error
            resolve(rows as TResult[]); // Si no, resolvemos con el resultado
        });
    });

De este modo podemos reaprovechar la función en diferentes escenarios.

interface Person {
    id: number,
    // ...
}

interface User {
    id: number,
    username: string
    // ...
}

(async () => {
    const [ user ] = await selectBy<User>(`user_table`, `username`, `rosa1`);
    const [ person ] = await selectBy<Person>(`person_table`, `personId`, user.id);

    console.log(user);
    console.log(person);
})();

Una vez con esto, ya se pueden sacar diferentes funciones que ahorren el paso de los parámetros user_table o person_table, por ejemplo.
La lógica interna será compartida, por lo que cualquier cambio se va a aplicar a todas las funciones delegadas, en vez de tener que ir una a una (lo cual es un foco de bugs).

const selectPerson = (id: number) => selectBy<Person>(`person_table`, `personId`, id);
const selectUser = (id: string) => selectBy<User>(`user_table`, `username`, id);

(async () => {
    const [ user ] = await selectUser('rosa1');
    const [ person ] = await selectPerson(user.id);

    console.log(user);
    console.log(person);
})();

Espero que sirva.

Origen Enlace
VRoxa
  • 3.1k
  • 8
  • 19

Puedes devolver una Promise que resuelva con la callback de query.
En este caso, una Promise explícita porque no hará falta usar await.

const userTable = (id: number) =>
    new Promise<any>((resolve, reject) => {
        pool.query('SELECT * FROM user_table WHERE userId = ?', [id],
        (err: any, rows: any, fields: any) => {
            if (err) reject(err); // En caso de error, resolvemos la Promise con error
            resolve(rows); // Si no, resolvemos con el resultado
        });
    });

Simplemente resolvemos o rechazamos la Promise con el resultado que devuelve la callback.
Y se puede llamar normal.

(async () => {
    try {
        const user = await userTable(0);
        console.log(user);
    } catch (err) {
        console.error(err);
    }
})();

///////////////////

userTable(0)
    .then(console.log)
    .catch(console.error);

Por último, desconozco si puedes hacerlo async/await. Por lo que veo, creo que no. Probablamente sea eso uno de los mayores cambios entre mysql y mysql2.

Espero que sirva.