Node.js mysql लेनदेन

अपडेट करें

async/प्रतीक्षा सिंटैक्स के लिए नीचे दिया गया संपादन देखें

मैंने कुछ समय नोड MySQL द्वारा दिए गए लेनदेन उदाहरण के सामान्यीकृत संस्करण को लिखने में बिताया, इसलिए मैंने सोचा कि मैं इसे यहां साझा करूंगा। मैं अपने वादे पुस्तकालय के रूप में ब्लूबर्ड का उपयोग कर रहा हूं, और इसका उपयोग कनेक्शन ऑब्जेक्ट को 'वादा' करने के लिए किया है जिसने अतुल्यकालिक तर्क को बहुत सरल बना दिया है।

const Promise = ('bluebird');
const mysql = ('mysql');

/**
 * Run multiple queries on the database using a transaction. A list of SQL queries
 * should be provided, along with a list of values to inject into the queries.
 * @param  {array} queries     An array of mysql queries. These can contain `?`s
 *                              which will be replaced with values in `queryValues`.
 * @param  {array} queryValues An array of arrays that is the same length as `queries`.
 *                              Each array in `queryValues` should contain values to
 *                              replace the `?`s in the corresponding query in `queries`.
 *                              If a query has no `?`s, an empty array should be provided.
 * @return {Promise}           A Promise that is fulfilled with an array of the
 *                              results of the passed in queries. The results in the
 *                              returned array are at respective positions to the
 *                              provided queries.
 */
function transaction(queries, queryValues) {
    if (queries.length !== queryValues.length) {
        return Promise.reject(
            'Number of provided queries did not match the number of provided query values arrays'
        )
    }

    const connection = mysql.createConnection(databaseConfigs);
    Promise.promisifyAll(connection);
    return connection.connectAsync()
    .then(connection.beginTransactionAsync())
    .then(() => {
        const queryPromises = [];

        queries.forEach((query, index) => {
            queryPromises.push(connection.queryAsync(query, queryValues[index]));
        });
        return Promise.all(queryPromises);
    })
    .then(results => {
        return connection.commitAsync()
        .then(connection.endAsync())
        .then(() => {
            return results;
        });
    })
    .catch(err => {
        return connection.rollbackAsync()
        .then(connection.endAsync())
        .then(() => {
            return Promise.reject(err);
        });
    });
}

यदि आप प्रश्न में सुझाए गए पूलिंग का उपयोग करना चाहते हैं, तो आप आसानी से createConnection स्विच कर सकते हैं myPool.getConnection(...) . के साथ लाइन , और स्विच करें connection.end connection.release() . के साथ लाइनें ।

संपादित करें

मैंने mysql2 . का उपयोग करके कोड की एक और पुनरावृत्ति की है पुस्तकालय (mysql . के समान एपीआई) लेकिन वादे के समर्थन के साथ) और नए async/प्रतीक्षा ऑपरेटर। ये रहा

const mysql = require('mysql2/promise')

/** See documentation from original answer */
async function transaction(queries, queryValues) {
    if (queries.length !== queryValues.length) {
        return Promise.reject(
            'Number of provided queries did not match the number of provided query values arrays'
        )
    }
    const connection = await mysql.createConnection(databaseConfigs)
    try {
        await connection.beginTransaction()
        const queryPromises = []

        queries.forEach((query, index) => {
            queryPromises.push(connection.query(query, queryValues[index]))
        })
        const results = await Promise.all(queryPromises)
        await connection.commit()
        await connection.end()
        return results
    } catch (err) {
        await connection.rollback()
        await connection.end()
        return Promise.reject(err)
    }
}