MySQL连接函数
MySQL是一款常用的关系型数据库管理系统,为了与MySQL数据库建立连接并进行数据操作,我们需要使用相应的连接函数。本文将为你详解MySQL连接函数的使用,包括连接配置和常用的函数示例。
一、连接配置
在使用MySQL连接函数之前,我们需要先配置连接参数,包括主机名、用户名、密码和要连接的数据库。以下是常用的连接配置参数:
- 主机名(hostname):MySQL服务器所在的主机名或IP地址。
- 用户名(username):用于连接MySQL的用户名。
- 密码(password):用户名对应的密码。
- 数据库(database):要连接的数据库名称。
在连接数据库之前,我们需要先安装MySQL驱动程序,以便与MySQL服务器建立连接。常见的MySQL驱动程序有mysql-connector-python
和pymysql
等。
以下是一个MySQL连接函数的示例代码:
import mysql.connector
# 配置连接参数
config = {
'host': 'localhost',
'username': 'root',
'password': '123456',
'database': 'mydatabase'
}
# 建立连接
conn = mysql.connector.connect(**config)
# 创建游标
cursor = conn.cursor()
# 执行SQL语句
cursor.execute("SELECT * FROM customers")
# 提交数据库操作
conn.commit()
# 关闭游标和连接
cursor.close()
conn.close()
二、常用的连接函数
下面介绍一些常用的MySQL连接函数及其使用方法。
1. connect()
connect()
函数用于建立与MySQL数据库的连接。它接受一个参数**kwargs
,用于传递连接配置参数。返回一个连接对象。
以下是connect()
函数的示例代码:
import mysql.connector
# 配置连接参数
config = {
'host': 'localhost',
'username': 'root',
'password': '123456',
'database': 'mydatabase'
}
# 建立连接
conn = mysql.connector.connect(**config)
2. cursor()
cursor()
函数用于创建一个游标对象,用于执行SQL语句并获取结果。返回一个游标对象。
以下是cursor()
函数的示例代码:
import mysql.connector
# 创建游标
cursor = conn.cursor()
3. execute()
execute()
函数用于执行SQL语句。它接受一个参数sql
,表示要执行的SQL语句。
以下是execute()
函数的示例代码:
import mysql.connector
# 执行SQL语句
cursor.execute("SELECT * FROM customers")
4. commit()
commit()
函数用于提交对数据库的操作。在执行插入、更新或删除等操作后,必须调用commit()
函数才能使修改生效。
以下是commit()
函数的示例代码:
import mysql.connector
# 提交数据库操作
conn.commit()
5. close()
close()
函数用于关闭游标和连接,释放相关资源。
以下是close()
函数的示例代码:
import mysql.connector
# 关闭游标和连接
cursor.close()
conn.close()
三、示例代码及运行结果
下面给出一些示例代码及其运行结果,以演示MySQL连接函数的使用方法。
示例1:连接MySQL数据库并查询记录
import mysql.connector
# 配置连接参数
config = {
'host': 'localhost',
'username': 'root',
'password': '123456',
'database': 'mydatabase'
}
# 建立连接
conn = mysql.connector.connect(**config)
# 创建游标
cursor = conn.cursor()
# 执行SQL语句
cursor.execute("SELECT * FROM customers")
# 获取查询结果
result = cursor.fetchall()
# 输出查询结果
for row in result:
print(row)
# 关闭游标和连接
cursor.close()
conn.close()
运行结果:
(1, 'John', 'Doe')
(2, 'Jane', 'Smith')
(3, 'David', 'Johnson')
示例2:插入记录到MySQL数据库
import mysql.connector
# 配置连接参数
config = {
'host': 'localhost',
'username': 'root',
'password': '123456',
'database': 'mydatabase'
}
# 建立连接
conn = mysql.connector.connect(**config)
# 创建游标
cursor = conn.cursor()
# 执行插入语句
sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
val = ("Alice", "123 Main St")
cursor.execute(sql, val)
# 提交数据库操作
conn.commit()
# 关闭游标和连接
cursor.close()
conn.close()
运行结果:数据库中插入一条新记录。
示例3:更新MySQL数据库中的记录
import mysql.connector
# 配置连接参数
config = {
'host': 'localhost',
'username': 'root',
'password': '123456',
'database': 'mydatabase'
}
# 建立连接
conn = mysql.connector.connect(**config)
# 创建游标
cursor = conn.cursor()
# 执行更新语句
sql = "UPDATE customers SET address = '456 Oak St' WHERE id = 2"
cursor.execute(sql)
# 提交数据库操作
conn.commit()
# 关闭游标和连接
cursor.close()
conn.close()
运行结果:更新数据库中id为2的记录的地址。
示例4:删除MySQL数据库中的记录
import mysql.connector
# 配置连接参数
config = {
'host': 'localhost',
'username': 'root',
'password': '123456',
'database': 'mydatabase'
}
# 建立连接
conn = mysql.connector.connect(**config)
# 创建游标
cursor = conn.cursor()
# 执行删除语句
sql = "DELETE FROM customers WHERE id = 3"
cursor.execute(sql)
# 提交数据库操作
conn.commit()
# 关闭游标和连接
cursor.close()
conn.close()
运行结果:删除数据库中id为3的记录。
示例5:使用参数化查询
import mysql.connector
# 配置连接参数
config = {
'host': 'localhost',
'username': 'root',
'password': '123456',
'database': 'mydatabase'
}
# 建立连接
conn = mysql.connector.connect(**config)
# 创建游标
cursor = conn.cursor()
# 执行参数化查询
sql = "SELECT * FROM customers WHERE name = %s"
val = ("John", )
cursor.execute(sql, val)
# 获取查询结果
result = cursor.fetchall()
# 输出查询结果
for row in result:
print(row)
# 关闭游标和连接
cursor.close()
conn.close()
运行结果:
(1, 'John', 'Doe')
四、总结
通过本文的介绍,我们了解了MySQL连接函数的使用方法和常用参数,以及一些示例代码。通过这些函数,我们可以与MySQL数据库建立连接并执行各种操作,包括查询、插入、更新和删除。