大数据教程【01.03】--MySQL 数据库

迭代棱镜
• 阅读 389

更多信息请关注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)

yourusernameyourpasswordyourdatabase 替换为实际的用户名、密码和数据库名称。运行以上代码后,将会输出数据库连接信息。

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 的数据表。该数据表包含三列:idnameage

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

点赞
收藏
评论区
推荐文章
Wesley13 Wesley13
3年前
java开发中的重中之重
介绍:  mysql是目前世界上最流行的关系型数据库,在国内大的互联网公司都在使用mysql数据库,mysql经常被我们这样概述,“mysql是轻量级关系型数据库”,其实轻量级并不是说mysql是中小型数据库,在项目开发中,存储数据的量往往是一个架构问题,如果配合架构,mysql也是可以存储海量数据的。并且海量数据并没有一个明确的标准。说mysq
Wesley13 Wesley13
3年前
MySQL与Oracle的区别
1. Oracle是大型数据库而Mysql是中小型数据库,Oracle市场占有率达40%,Mysql只有20%左右,同时Mysql是开源的而Oracle价格非常高。2\.Oracle支持大并发,大访问量,是OLTP最好的工具。3\.安装所用的空间差别也是很大的,Mysql安装完后才152M而Oracle有3G左右,且使用的时候Oracle占用特
Wesley13 Wesley13
3年前
mySQL (关系型数据库管理系统)
MySQL是一个关系型数据库管理系统,由瑞典MySQLAB公司开发,目前属于 Oracle 旗下产品。MySQL是最流行的关系型数据库管理系统之一,在WEB应用方面,MySQL是最好的RDBMS(RelationalDatabaseManagementSystem,关系数据库管理系统)应用软件。MySQL是一种关系数据库管理系统,关
Wesley13 Wesley13
3年前
mysql企业实战(一)
一、简介MySQL是最流行的开放源码SQL数据库管理系统,它是由MySQLAB公司开发、发布并支持的。有以下特点:MySQL是一种数据库管理系统。MySQL是一种关联数据库管理系统。MySQL软件是一种开放源码软件。MySQL数据库服务器具有快速、可靠和易于使用的特点。MySQL服务器工作在
Wesley13 Wesley13
3年前
MySQL系列(一)
一、简介MySQL是最流行的开放源码SQL数据库管理系统,它是由MySQLAB公司开发、发布并支持的。有以下特点:MySQL是一种数据库管理系统。MySQL是一种关联数据库管理系统。MySQL软件是一种开放源码软件。MySQL数据库服务器具有快速、可靠和易于使用的特点。MySQL服务器工作在客户端/服务器模
Wesley13 Wesley13
3年前
mysql面试题总结
1.Mysql中的myisam与innodb的区别?2.InnoDB存储引擎的四大特性?3.什么是事务?4.数据库事务的四大特性?5.不考虑事务的隔离性,会发生几种问题?6.MySQL数据库提供的四种隔离级别?7.有多少种日志?8.事务是如何通过日志来实现的?9.数据库的乐观锁和悲观锁是什么?10.什
Wesley13 Wesley13
3年前
Mysql用户与权限操作
1.用户与权限概述用户是数据库的使用者和管理者。MySQL通过用户的设置来控制数据库操作人员的访问与操作范围。服务器中名为mysqI的数据库,用于维护数据库的用户以及权限的控制和管理。MySQL中的所有用户信息都保存在mysql.user数据表中。根据my
Wesley13 Wesley13
3年前
MySQL学习笔记(一)
一,数据库系统概念数据库:指装数据的库(硬盘空间)。数据库管理软件:指在操作系统上用户所使用的管理数据库的应用软件(MySQL、Oracle等)数据库系统:是包含数据管理员,数据库,数据管理软件的统称。二,Mysql的的的的的安装这个不多赘述,网上教程很多,自行百度即可。安装好MySQL后,先不要着急安装可视化工具,可
Vitess全局唯一ID生成的实现方案 | 京东云技术团队
为了标识一段数据,通常我们会为其指定一个唯一id,比如利用MySQL数据库中的自增主键。但是当数据量非常大时,仅靠数据库的自增主键是远远不够的,并且对于分布式数据库只依赖MySQL的自增id无法满足全局唯一的需求。因此,产生了多种解决方案,如UUID,Sn
小万哥 小万哥
1年前
Python 数据库应用教程:安装 MySQL 及使用 MySQL Connector
Python可以用于数据库应用程序。其中最流行的数据库之一是MySQL。MySQL数据库为了能够在本教程中尝试代码示例,您应该在计算机上安装MySQL。您可以在下载MySQL数据库。安装MySQL驱动程序Python需要一个MySQL驱动程序来访问MySQ