指定数据库连接信息

网站编辑2023-06-20 12:29:53194

1. 连接数据库

在进行数据库操作之前，首先需要连接到数据库。连接数据库的方法通常包括以下几个步骤：

1. 导入数据库驱动程序
2. 指定数据库连接信息，如数据库地址、用户名、密码等
3. 建立数据库连接

以下是一个连接 MySQL 数据库的示例代码：

```python import mysql.connector

config = { 'user': 'root', 'password': 'password', 'host': 'localhost', 'database': 'test' }

cnx = mysql.connector.connect(**config) ```

2. 执行 SQL 语句

连接到数据库后，就可以执行 SQL 语句了。SQL 语句通常包括增、删、改、查四种操作，分别对应 SQL 语句中的 INSERT、DELETE、UPDATE 和 SELECT。

以下是一个执行 SELECT 语句的示例代码：

```python import mysql.connector

config = { 'user': 'root', 'password': 'password', 'host': 'localhost', 'database': 'test' }

cnx = mysql.connector.connect(**config)

cursor = cnx.cursor()

query = "SELECT * FROM users" cursor.execute(query)

for (id, name, age) in cursor: print("{} - {} - {}".format(id, name, age))

cursor.close() cnx.close() ```

3. 提交事务

在进行数据库操作时，通常需要开启一个事务。事务是一组操作，要么全部执行成功，要么全部回滚。在 Python 中，可以使用 cnx.commit() 提交事务，使用 cnx.rollback() 回滚事务。

以下是一个使用事务的示例代码：

```python import mysql.connector

config = { 'user': 'root', 'password': 'password', 'host': 'localhost', 'database': 'test' }

cnx = mysql.connector.connect(**config)

cursor = cnx.cursor()

cnx.start_transaction()

query1 = "INSERT INTO users (name, age) VALUES ('Tom', 20)" query2 = "UPDATE users SET age = 21 WHERE name = 'Tom'" cursor.execute(query1) cursor.execute(query2)

cnx.commit()

cursor.close() cnx.close() ```

以上是数据库操作的基本方法，可以根据具体需求进行调整和扩展。