Lua 连接操作 MySQL 数据库的详细指南

2023-12-11 17:19:21

在 Lua 中操纵 MySQL 数据库的终极指南

在 Lua 中操作 MySQL 数据库对于创建强大且数据驱动的应用程序至关重要。本文将深入探讨连接、查询、更新、删除和优化数据库操作的关键步骤。

1. 连接 MySQL 数据库

连接到 MySQL 数据库需要使用 mysql 模块和一个连接池对象。连接池允许重用连接，从而提高性能。以下代码示例演示了如何进行连接：

local mysql = require("mysql")
local pool = mysql.createPool({
  host = "localhost",
  port = 3306,
  user = "username",
  password = "password",
  database = "database_name",
  connectionLimit = 10,
  waitForConnections = true
})

2. 执行查询

要执行 SQL 查询，可以使用 query() 方法。查询回调函数会返回查询结果或任何错误。

pool.query("SELECT * FROM table_name", function(err, rows, fields) {
  if (err) {
    print(err.message)
  } else {
    for (i = 1, #rows) do
      print(rows[i].column_name)
    end
  }
})

3. 更新数据

可以使用 execute() 方法来更新数据库中的数据。

pool.execute("UPDATE table_name SET column_name = ? WHERE id = ?", { "new_value", 1 }, function(err, result) {
  if (err) {
    print(err.message)
  } else {
    print("更新成功，影响行数：" .. result.affectedRows)
  }
})

4. 删除数据

与更新类似，可以使用 execute() 方法删除数据。

pool.execute("DELETE FROM table_name WHERE id = ?", { 1 }, function(err, result) {
  if (err) {
    print(err.message)
  } else {
    print("删除成功，影响行数：" .. result.affectedRows)
  }
})

5. 使用事务

事务可用于确保数据库操作的原子性、一致性、隔离性和持久性。以下示例展示了如何使用事务：

pool.beginTransaction(function(err) {
  if (err) {
    print(err.message)
  } else {
    pool.execute("UPDATE table_name SET column_name = ? WHERE id = ?", { "new_value", 1 }, function(err, result) {
      if (err) {
        pool.rollback(function(err) {
          if (err) {
            print(err.message)
          }
        })
      } else {
        pool.commit(function(err) {
          if (err) {
            print(err.message)
          }
        })
      }
    })
  }
})