Nodejs数据库连接与操作插件mariadb的使用

Nodejs数据库连接与操作插件mariadb的使用
mariadb 是一个用于 Node.js 的 MariaDB/MySQL 数据库客户端。下面是一些基本的使用示例，包括如何连接到数据库、执行查询和处理结果。

1. 安装 mariadb

首先，你需要安装 mariadb 包。你可以使用 npm 来安装：

npm install mariadb

2. 连接到数据库

以下是一个简单的连接示例：

const mariadb = require('mariadb');

// 创建一个连接池
const pool = mariadb.createPool({
    host: 'your_host',
    user: 'your_user',
    password: 'your_password',
    database: 'your_database'
});

// 获取连接
async function getConnection() {
    let conn;
    try {
        conn = await pool.getConnection();
        console.log("Connected to the database!");
    } catch (err) {
        console.error("Error connecting to the database:", err);
    }
    return conn;
}

3. 执行查询

你可以使用连接对象来执行 SQL 查询。这里有一个示例，展示了如何插入数据和查询数据：

async function insertData(conn) {
    const query = "INSERT INTO your_table (column1, column2) VALUES (?, ?)";
    const values = ['value1', 'value2'];
    try {
        const result = await conn.query(query, values);
        console.log(`Inserted with ID: ${result.insertId}`);
    } catch (err) {
        console.error("Error inserting data:", err);
    }
}

async function fetchData(conn) {
    const query = "SELECT * FROM your_table";
    try {
        const rows = await conn.query(query);
        console.log(rows);
    } catch (err) {
        console.error("Error fetching data:", err);
    }
}

// 使用函数
(async () => {
    const conn = await getConnection();
    if (conn) {
        await insertData(conn);
        await fetchData(conn);
        // 释放连接
        conn.release();
    }
})();

4. 处理事务

你还可以在事务中执行多个查询，以确保所有操作都成功或全部失败：

async function runTransaction(conn) {
    const query1 = "UPDATE your_table SET column1 = ? WHERE id = ?";
    const query2 = "INSERT INTO another_table (column1) VALUES (?)";

    try {
        await conn.beginTransaction();
        await conn.query(query1, ['new_value', 1]);
        await conn.query(query2, ['new_value']);
        await conn.commit();
        console.log("Transaction completed successfully.");
    } catch (err) {
        await conn.rollback();
        console.error("Transaction failed:", err);
    }
}

// 使用事务
(async () => {
    const conn = await getConnection();
    if (conn) {
        await runTransaction(conn);
        conn.release();
    }
})();

以上就是使用 mariadb 插件进行数据库连接和操作的基本示例。你可以根据需要调整这些代码以适应你的具体需求。


3 回复

当然，说到Node.js和MariaDB的结合，你可以用mariadb这个插件来连接和操作MariaDB数据库。首先，你需要安装它，通过运行npm install mariadb来搞定。

接下来，你可以开始创建一个连接：

const mariadb = require('mariadb');
const pool = mariadb.createPool({
    host: 'your_host',
    user: 'your_user',
    password: 'your_password',
    database: 'your_database'
});

然后，你可以从池中获取连接并执行SQL查询：

async function getConnection() {
    let conn;
    try {
        conn = await pool.getConnection();
        const queryResult = await conn.query('SELECT * FROM your_table');
        console.log(queryResult);
    } catch (err) {
        throw err;
    } finally {
        if (conn) conn.release(); //释放连接
    }
}

这样，你就能够愉快地在Node.js中操作MariaDB了！记得处理好错误哦。


mariadb 是一个用于 Node.js 的 MariaDB 和 MySQL 数据库驱动。以下是使用 mariadb 连接数据库以及进行基本查询操作的示例。

安装 mariadb

首先，你需要安装 mariadb 包。可以通过 npm 来安装：

npm install mariadb

连接到数据库

以下是一个简单的示例，展示如何使用 mariadb 连接到数据库并执行一些基本操作：

const mariadb = require('mariadb');

// 创建一个连接池
const pool = mariadb.createPool({
    host: 'localhost', // 数据库服务器地址
    user: 'yourUsername', // 数据库用户名
    password: 'yourPassword', // 数据库密码
    database: 'yourDatabaseName' // 要使用的数据库名
});

async function getConnection() {
    let conn;
    try {
        // 从连接池获取连接
        conn = await pool.getConnection();
        
        // 执行查询
        const queryResult = await conn.query("SELECT * FROM yourTableName");
        console.log(queryResult);

        // 插入数据
        const insertResult = await conn.query(
            "INSERT INTO yourTableName (column1, column2) VALUES (?, ?)",
            ['value1', 'value2']
        );
        console.log(`Inserted with ID ${insertResult.insertId}`);
    } catch (err) {
        console.error(err);
    } finally {
        if (conn) conn.release(); // 释放连接
    }
}

getConnection();

解释

  • 创建连接池：我们通过 createPool 方法创建了一个连接池，这样可以更高效地管理数据库连接。
  • 获取连接：使用 pool.getConnection() 获取到数据库连接。
  • 执行查询：通过 conn.query 方法执行 SQL 查询。
  • 插入数据：同样使用 conn.query 方法，但这次是插入新数据。注意参数化查询可以防止 SQL 注入攻击。
  • 错误处理：使用 try...catch 块来捕获可能发生的错误，并确保在操作完成后正确关闭或释放连接。

请根据你的实际需求调整数据库配置信息、表名和列名等细节。

Node.js 中使用 mariadb 插件连接和操作 MariaDB 数据库，首先需要安装该插件：

npm install mariadb

然后你可以创建一个连接池来管理数据库连接：

const mariadb = require('mariadb');

const pool = mariadb.createPool({
    host: 'your_host',
    user: 'your_user',
    password: 'your_password',
    database: 'your_database'
});

执行查询或命令可以通过获取连接并执行 SQL 语句：

async function queryDatabase() {
    let conn;
    try {
        conn = await pool.getConnection();
        const rows = await conn.query('SELECT * FROM your_table');
        console.log(rows);
    } catch (err) {
        throw err;
    } finally {
        if (conn) conn.release(); // 返回连接池
    }
}

这样可以有效地管理数据库连接并进行数据库操作。

回到顶部