Function ExecuteTransaction

src/db/Query.js:68–109

(dbId, queries, params, callback)

}

async function ExecuteTransaction(dbId, queries, params, callback) {
    const connection = await GetConnection(dbId);
    await connection.beginTransaction();
    try {
        const queryPromises = queries.map((queryObject) => {
            if (queryObject["query"].includes("@")) {
                queryObject["query"] = ReplaceNamedParams(queryObject["query"], queryObject["values"] == null ? (params != null ? params : []) : queryObject["values"])
                queryObject["values"] = null;
            }
            return connection.query(queryObject["query"], queryObject["values"] == null ? (params != null ? params : []) : queryObject["values"]);
        });
        const results = await Promise.allSettled(queryPromises);
        const hasErrors = results.some((result) => {
            if (result.reason && result.reason.message) {
                ParseError(`Error while executing query: ${result.reason.message} `);
            }
            return result.status === "rejected"
        });
        if (hasErrors) {
            await connection.rollback();
            ParseError("Some queries failed while executing transaction.");
            if (typeof callback === "function") {
                callback(false);
            }
            return false;
        }
        await connection.commit();
        connection.release();
        if (typeof callback === "function") {
            callback(true);
        }
        return true;
    } catch (err) {
        await connection.rollback();
        connection.release();
        ParseError(`Error while executing transaction: ${err.message} `);
        if (typeof callback === "function") {
            callback(false);
        }
        return false;
    }
}

function AddMethod(type) {
    const method = async function(dbId, query, values, callback, cache) {