连接数据库需要先安装相应的数据库驱动,例如MySQL需要安装mysql-connector-python包。
import mysql.connector
#连接数据库
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
password="yourpassword",
database="mydatabase"
)
print(mydb)
创建表需要使用SQL语句,在Python中可以使用execute()方法执行SQL语句。
mycursor = mydb.cursor()
#创建表
mycursor.execute("CREATE TABLE customers (name VARCHAR(255), address VARCHAR(255))")
插入数据也需要使用SQL语句,在Python中可以使用execute()方法执行SQL语句。
mycursor = mydb.cursor()
#插入数据
sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
val = ("John", "Highway 21")
mycursor.execute(sql, val)
mydb.commit()
print(mycursor.rowcount, "record inserted.")
查询数据需要使用SELECT语句,在Python中可以使用execute()方法执行SELECT语句,并使用fetchall()方法获取所有数据。
mycursor = mydb.cursor()
#查询数据
mycursor.execute("SELECT * FROM customers")
myresult = mycursor.fetchall()
for x in myresult:
print(x)
更新数据需要使用UPDATE语句,在Python中可以使用execute()方法执行UPDATE语句。
mycursor = mydb.cursor()
#更新数据
sql = "UPDATE customers SET address = 'Canyon 123' WHERE name = 'John'"
mycursor.execute(sql)
mydb.commit()
print(mycursor.rowcount, "record(s) affected")
删除数据需要使用DELETE语句,在Python中可以使用execute()方法执行DELETE语句。
mycursor = mydb.cursor()
#删除数据
sql = "DELETE FROM customers WHERE name = 'John'"
mycursor.execute(sql)
mydb.commit()
print(mycursor.rowcount, "record(s) deleted")