欢迎访问宙启技术站
智能推送

Python数据库函数,连接和查询数据库

发布时间:2023-07-01 17:14:19

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连接和查询数据库非常简单。我们只需要导入相应的数据库驱动程序,并使用相应的函数即可。当然,在实际应用中,还需要处理各种异常情况,并对查询结果进行进一步处理和展示。