关于程序员:大数据教程0103MySQL-数据库

更多信息请关注 WX 搜寻 GZH：XiaoBaiGPT

大数据与 MySQL 数据库

本教程将介绍大数据与 MySQL 数据库的相干常识，并提供应用 Python 编程语言的示例。大数据是指规模宏大、复杂度高、难以通过传统数据处理工具进行捕获、治理和解决的数据汇合。MySQL 是一种风行的关系型数据库管理系统，罕用于存储和治理结构化数据。

目录

1. 筹备工作
2. 连贯到 MySQL 数据库
3. 创立数据库和数据表
4. 插入数据
5. 查问数据
6. 更新和删除数据
7. 敞开数据库连贯

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 多平台公布