Python数据库函数,连接和查询数据库
Python是一种非常强大的编程语言,支持多种数据库操作。在Python中,我们可以通过使用数据库函数来连接和查询数据库。
首先,我们需要安装Python数据库驱动程序。常用的Python数据库驱动程序包括:MySQLdb、psycopg2、sqlite3等。接下来,我们将以MySQL数据库为例,介绍如何连接和查询数据库。
连接数据库:
要连接到MySQL数据库,我们需要导入mysql.connector库,并使用connect()函数创建一个数据库连接。在connect()函数中,我们需要传入数据库服务器的主机名、用户名、密码和数据库名等参数。
例如,以下代码连接到localhost主机上的test数据库,并使用root用户和123456密码进行身份验证:
import mysql.connector mydb = mysql.connector.connect( host="localhost", user="root", password="123456", database="test" )
查询数据库:
一旦连接成功,我们就可以执行SQL查询语句来查询数据库。
要执行查询,我们需要创建一个游标对象。使用游标对象,我们可以执行SQL查询,并获取查询结果。
例如,以下代码查询名为students的表,并打印查询结果:
import mysql.connector
mydb = mysql.connector.connect(
host="localhost",
user="root",
password="123456",
database="test"
)
mycursor = mydb.cursor()
mycursor.execute("SELECT * FROM students")
result = mycursor.fetchall()
for row in result:
print(row)
在上面的代码中,我们首先创建了一个游标对象mycursor,然后使用execute()函数执行SQL查询语句。查询结果可以使用fetchall()函数获取,并以列表的形式返回。
然后,我们使用for循环遍历查询结果,并打印每一行数据。
除了SELECT语句外,我们还可以执行INSERT、UPDATE和DELETE等语句来对数据库进行增、删和改操作。例如,以下代码向students表中插入一条新记录:
import mysql.connector
mydb = mysql.connector.connect(
host="localhost",
user="root",
password="123456",
database="test"
)
mycursor = mydb.cursor()
sql = "INSERT INTO students (name, age, gender) VALUES (%s, %s, %s)"
val = ("Jack", 20, "Male")
mycursor.execute(sql, val)
mydb.commit()
print(mycursor.rowcount, "record inserted.")
在上面的代码中,我们首先定义了一条插入语句sql,并使用execute()函数执行该语句。然后,我们调用commit()函数来提交事务。
最后,我们可以使用rowcount属性获取受影响的行数,并打印出插入记录的数量。
通过以上示例,我们可以看到,使用Python连接和查询数据库非常简单。我们只需要导入相应的数据库驱动程序,并使用相应的函数即可。当然,在实际应用中,还需要处理各种异常情况,并对查询结果进行进一步处理和展示。
