更多信息请关注 WX 搜寻 GZH:XiaoBaiGPT
大数据与 MySQL 数据库
本教程将介绍大数据与 MySQL 数据库的相干常识,并提供应用 Python 编程语言的示例。大数据是指规模宏大、复杂度高、难以通过传统数据处理工具进行捕获、治理和解决的数据汇合。MySQL 是一种风行的关系型数据库管理系统,罕用于存储和治理结构化数据。
目录
- 筹备工作
- 连贯到 MySQL 数据库
- 创立数据库和数据表
- 插入数据
- 查问数据
- 更新和删除数据
- 敞开数据库连贯
1. 筹备工作
在开始之前,请确保曾经实现以下筹备工作:
- 装置 MySQL 数据库,并启动数据库服务。
- 装置 Python,并确保曾经装置了
mysql-connector-python
模块,可应用以下命令进行装置:
pip install mysql-connector-python
2. 连贯到 MySQL 数据库
首先,咱们须要应用 Python 连贯到 MySQL 数据库。上面是一个连贯到本地 MySQL 数据库的示例:
import mysql.connector
# 连贯数据库
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
password="yourpassword",
database="yourdatabase"
)
# 打印数据库连贯信息
print(mydb)
将 yourusername
、yourpassword
和 yourdatabase
替换为理论的用户名、明码和数据库名称。运行以上代码后,将会输入数据库连贯信息。
3. 创立数据库和数据表
在开始存储数据之前,咱们须要创立一个数据库和数据表。上面是一个示例,创立一个名为 employees
的数据库,并在其中创立一个名为 employees_info
的数据表:
import mysql.connector
# 连贯数据库
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
password="yourpassword",
database="yourdatabase"
)
# 创立数据库
mycursor = mydb.cursor()
mycursor.execute("CREATE DATABASE employees")
# 创立数据表
mycursor.execute("USE employees")
mycursor.execute("CREATE TABLE employees_info (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)")
在以上示例中,咱们应用 CREATE DATABASE
语句创立了一个名为 employees
的数据库,并应用 CREATE TABLE
语句在其中创立了一个名为 employees_info
的数据表。该数据表蕴含三列:id
、name
和 age
。
4. 插入数据
接下来,咱们将演示如何向数据表中插入数据。以下是一个示例,向 employees_info
数据表插入一条员工信息记录:
import mysql.connector
# 连贯数据库
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
password="yourpassword",
database="yourdatabase"
)
# 插入数据
mycursor = mydb.cursor()
sql = "INSERT INTO employees_info (name, age) VALUES (%s, %s)"
val = ("John Doe", 30)
mycursor.execute
(sql, val)
# 提交事务
mydb.commit()
# 输入插入的记录 ID
print("插入胜利,记录 ID:", mycursor.lastrowid)
在以上示例中,咱们应用 INSERT INTO
语句将一条员工信息记录插入到 employees_info
数据表中。应用 %s
占位符来指定要插入的值,并通过元组 val
传递这些值。最初,咱们应用 mydb.commit()
提交事务,并通过 mycursor.lastrowid
输入插入记录的 ID。
5. 查问数据
一旦数据被插入到数据表中,咱们能够执行查问操作来检索数据。以下是一个示例,查问 employees_info
数据表中的所有员工信息记录:
import mysql.connector
# 连贯数据库
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
password="yourpassword",
database="yourdatabase"
)
# 查问数据
mycursor = mydb.cursor()
mycursor.execute("SELECT * FROM employees_info")
# 获取查问后果
result = mycursor.fetchall()
# 输入查问后果
for row in result:
print(row)
在以上示例中,咱们应用 SELECT * FROM
语句查问了 employees_info
数据表中的所有记录。通过 mycursor.fetchall()
办法获取查问后果,并应用 for
循环遍历输入每一行记录。
6. 更新和删除数据
除了插入和查问数据,咱们还能够执行更新和删除操作。以下是一些示例,演示如何更新和删除 employees_info
数据表中的记录:
更新数据示例:
import mysql.connector
# 连贯数据库
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
password="yourpassword",
database="yourdatabase"
)
# 更新数据
mycursor = mydb.cursor()
sql = "UPDATE employees_info SET age = %s WHERE name = %s"
val = (35, "John Doe")
mycursor.execute(sql, val)
# 提交事务
mydb.commit()
# 输入受影响的行数
print("更新胜利,受影响的行数:", mycursor.rowcount)
在以上示例中,咱们应用 UPDATE
语句更新了 employees_info
数据表中名为 “John Doe” 的员工的年龄。应用 %s
占位符指定要更新的值,并通过元组 val
传递这些值。最初,通过 mydb.commit()
提交事务,并通过 mycursor.rowcount
输入受影响的行数。
删除数据示例:
import mysql.connector
# 连贯数据库
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
password="yourpassword",
database="yourdatabase"
)
# 删除数据
mycursor = mydb.cursor()
sql = "DELETE FROM employees_info WHERE name = %s"
val = ("John Doe",)
mycursor.execute(sql, val)
# 提交事务
mydb.commit()
# 输入受影响的行数
print("删除胜利,受影响的行数:", mycursor.rowcount)
在以上示例中,咱们应用 DELETE FROM
语句删除了 employees_info
数据表中名为 “John Doe” 的员工记录。应用 %s
占位符指定要删除的值,并通过元组 val
传递这些值。最初,通过 mydb.commit()
提交事务,并通过 mycursor.rowcount
输入受影响的行数。
7. 敞开数据库连贯
实现所有数据库操作后,咱们应该敞开数据库连贯以开释资源。以下是一个示例:
import mysql.connector
# 连贯数据库
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
password="yourpassword",
database="yourdatabase"
)
# 执行数据库操作...
# 敞开数据库连贯
mydb.close()
在以上示例中,咱们应用 mydb.close()
办法敞开数据库连贯。
本文由 mdnice 多平台公布