从对象创建动态 Mysql 插入

Question

我在 Typescript 中有一个项目，我试图通过我通过object 发送的选项创建一个插入。现在我有两个对象，每个插入一个，这些插入是在不同的表和不同的对象中创建的。我想知道是否可以为多个对象创建通用插入。

这是我目前拥有的：

let object1 = [
    { country: 'CO', name: 'CO_SE.xml', exists: 1 },
    { country: 'CO', name: 'CO_IN.xml', exists: 1 },
    { country: 'CO', name: 'CO_BR.xml', exists: 1 }
];

`INSERT INTO ${database} VALUES` + object1.map((elem: any) => 
                    `"${elem.country}", "${elem.name}", ${elem.exists})`).join(', ');

let object2 = [
    { code: 1, folder: '/ToFtp', max: 8 },
    { code: 2, folder: '/ToXml', max: 5 },
    { code: 3, folder: '/ToMail', max: 5 }
];

`INSERT INTO ${database} VALUES` + object2.map((elem: any) => 
                    `${elem.code}, "${elem.folder}", ${elem.max})`).join(', ');

这就是我想要达到的目标：

let object1 = [
    { country: 'CO', name: 'CO_SE.xml', exists: 1 },
    { country: 'CO', name: 'CO_IN.xml', exists: 1 },
    { country: 'CO', name: 'CO_BR.xml', exists: 1 }
];

let object2 = [
    { code: 1, folder: '/ToFtp', max: 8 },
    { code: 2, folder: '/ToXml', max: 5 },
    { code: 3, folder: '/ToMail', max: 5 }
];

`INSERT INTO ${database} VALUES` + ${object}.map((elem: any) => 
                    `"${elem.elem1}", ... ${elem.elemN})`).join(', ');

这可能吗？我不确定这是否可以做到。

Answer 1

您可以创建方法来准备查询和值。你可以这样做。

let object1 = [
    { country: 'CO', name: 'CO_SE.xml', exists: 1 },
    { country: 'CO', name: 'CO_IN.xml', exists: 1 },
    { country: 'CO', name: 'CO_BR.xml', exists: 1 }
];

function getValues<T extends Record<string, any>[]>(obj: T) {
    const values = obj.map((item) => {
        const val = Object.values(item).map((v) => v);
        return val;
    });
    return values;
}

function getColumns<T extends Record<string, any>>(obj: T) {
    return Object.keys(obj);
}

function getFilters<T extends Record<string, any>>(obj: T) {
    const constraints: string[] = [];
    const queryArray: any[] = [];
    Object.entries(obj).forEach(([k, v]) => {
        constraints.push(`${k} = ?`);
        queryArray.push(v);
    });
    return {
        constraints,
        queryArray
    }
}

const columns = getColumns(object1[0]);
const values = getValues(object1);

const sql = `INSERT INTO MyTable(${columns.join(", ")}) VALUES ?`;

const filters = {
    country: "CO"
};
const selectFilters = getFilters(filters);

const selectSql = `SELECT ${columns} FROM MyTable WHERE ${selectFilters.constraints.join(" AND ")}`;

console.log(columns); // [ 'country', 'name', 'exists' ]
console.log(sql); // INSERT INTO MyTable(country, name, exists) VALUES ?
console.log(values); // [ [ 'CO', 'CO_SE.xml', 1 ], [ 'CO', 'CO_IN.xml', 1 ], [ 'CO', 'CO_BR.xml', 1 ] ]

// now you can use something like this
connection.query({ sql, values });

注意：请确保在使用这些功能之前清理您的输入，以避免如果您的输入与您期望的不一样，您可能会造成任何损害。