熟悉MySQL和HDFS操作

news/2024/5/20 4:09:13 标签: mysql, 数据库, hdfs, 大数据

1.使用Python操作MySQL数据库

在Windows系统中安装好MySQL8.0.23和Python3.8.7,然后再完成下面题目中的各项操作。

现有以下三个表格:

表1 学生表:Student(主码为Sno)

学号(Sno)

姓名(Sname)

性别(Ssex)

年龄(Sage)

所在系别(Sdept)

10001

Jack

21

CS

10002

Rose

20

SE

10003

Michael

21

IS

10004

Hepburn

19

CS

10005

Lisa

20

SE

表2 课程表:Course(主码为Cno)

课程号(Cno)

课程名(Cname)

学分(Credit)

00001

DataBase

4

00002

DataStructure

4

00003

Algorithms

3

00004

OperatingSystems

5

00005

ComputerNetwork

4

表3 选课表:SC(主码为Sno,Cno)

学号(Sno)

课程号(Cno)

成绩(Grade)

10002

00003

86

10001

00002

90

10002

00004

70

10003

00001

85

10004

00002

77

10005

00003

88

10001

00005

91

10002

00002

79

10003

00002

83

10004

00003

67

通过编程实现以下题目:

  1. 查询学号为10002学生的所有成绩,结果中需包含学号、姓名、所在系别、课程号、课程名以及对应成绩。
    import pymysql.cursors
    connect = pymysql.Connect(
        host='localhost', 
        port=3306, 
        user='root', 
        passwd='abc123',
        db='school',  
        charset='utf8' 
    )
    cursor = connect.cursor()
    cursor.execute("""
    SELECT Student.Sno, Student.Sname, Student.Sdept, Course.Cno, Course.Cname, SC.Grade
    FROM Student
    JOIN SC ON Student.Sno = SC.Sno
    JOIN Course ON SC.Cno = Course.Cno
    WHERE Student.Sno = '10002';
    """)
    result = cursor.fetchall()
    for x in result:
      print(x)
    connect.close()

  2. 查询每位学生成绩大于85的课程,结果中需包含学号、姓名、所在系别、课程号、课程名以及对应成绩。
    import pymysql.cursors
    connect = pymysql.Connect(
        host='localhost', 
        port=3306,
        user='root', 
        passwd='abc123',
        db='school', 
        charset='utf8' 
    )
    cursor = connect.cursor()
    cursor.execute("""
    SELECT Student.Sno, Student.Sname, Student.Sdept, Course.Cno, Course.Cname, SC.Grade
    FROM Student
    JOIN SC ON Student.Sno = SC.Sno
    JOIN Course ON SC.Cno = Course.Cno
    WHERE SC.Grade > 85;
    """)
    result = cursor.fetchall()
    for x in result:
      print(x)
    connect.close()

  3. 由于培养计划改,现需将课程号为00001、课程名为DataBase的学分改为5学分。
    import pymysql.cursors
    connect = pymysql.Connect(
        host='localhost', 
        port=3306, 
        user='root', 
        passwd='abc123', 
        db='school',  
        charset='utf8' 
    )
    cursor = connect.cursor()
    cursor.execute("""
    UPDATE Course
    SET Credit = 5
    WHERE Cno = '00001' AND Cname = 'DataBase';
    """)
    print("修改成功!")
    cursor.execute("""
    SELECT Cno,Cname, Credit
    FROM Course
    WHERE Cno = '00001';
    """)
    result = cursor.fetchone()
    print(result)
    connect.close()

  4. 将学号为10005的学生, OperatingSystems(00004)成绩为73分这一记录写入选课表中。
    import pymysql.cursors
    connect = pymysql.Connect(
        host='localhost', 
        port=3306,  
        user='root', 
        passwd='abc123', 
        db='school',  
        charset='utf8' 
    )
    cursor = connect.cursor()
    cursor.execute("""
    INSERT INTO SC (Sno, Cno, Grade)
    VALUES ('10005', '00004', 73);
    """)
    connect.commit()
    print("添加成功!")
    cursor.execute("""
    SELECT Student.Sno, Student.Sname, Student.Sdept, Course.Cno, Course.Cname, SC.Grade
    FROM Student
    JOIN SC ON Student.Sno = SC.Sno
    JOIN Course ON SC.Cno = Course.Cno
    WHERE Student.Sno = '10005';
    """)
    result = cursor.fetchall()
    for x in result:
      print(x)
    connect.close()

  5. 将学号为10003的学生从这三个表中删除。
    import pymysql.cursors
    connect = pymysql.Connect(
        host='localhost',  
        port=3306,  
        user='root',  
        passwd='abc123', 
        db='school',  
        charset='utf8' 
    )
    cursor = connect.cursor()
    cursor = connect.cursor()
    cursor.execute("""
    DELETE FROM Student WHERE Sno = '10003';
    """)
    connect.commit()
    cursor.execute("""
    DELETE FROM SC WHERE Sno = '10003';
    """)
    connect.commit()
    print("删除成功!")
    connect.close()

2.使用Shell命令操作HDFS 

在Windows系统中安装Hadoop3.1.3,然后完成下面题目中的各项操作:

        1.使用自己的用户名登录Windows系统,启动Hadoop,为当前登录的Windows用户在HDFS中创建用户目录“/user/[用户名]”;

hadoop fs -mkdir /user
hadoop fs -mkdir /user/xiaoguan
hadoop fs -ls /user

        2.接着在HDFS的目录“/user/[用户名]”下,创建test目录;

hadoop fs -mkdir /user/xiaoguan/test
hadoop fs -ls /user/xiaoguan

         3.将Windows系统本地的一个文件上传到HDFS的test目录中,并查看上传后的文件内容;

hadoop fs -put E:\test.txt /user/xiaoguan/test
hadoop fs -ls /user/xiaoguan/test
hadoop fs -cat /user/xiaoguan/test/test.txt

         4.将HDFS目录test复制到Windows本地文件系统的某个目录下。

hadoop fs -get /user/xiaoguan/test/test.txt D:\test
dir D:\test

http://www.niftyadmin.cn/n/5090835.html

相关文章

LeetCode讲解篇之138. 随机链表的复制

LeetCode讲解篇之138. 随机链表的复制 文章目录 LeetCode讲解篇之138. 随机链表的复制题目描述题解思路题解代码 题目描述 题解思路 先遍历一遍链表,用哈希表保存原始节点和克隆节点的映射关系,先只克隆节点的Val,然后再次遍历链表&#xff…

Hadoop3教程(八):MapReduce中的序列化概述

文章目录 (79)MR序列化概述(80)自定义序列化步骤(81)序列化案例需求分析(82)序列化案例代码参考文献 (79)MR序列化概述 什么是序列化,什么是反序…

访问量突破1W,纪念一下~

Mr.kanglong, 继续加油!

学习笔记-MongoDB(复制集,分片集集群搭建)

复制集群搭建 基本介绍 什么是复制集? 复制集是由一组拥有相同数据集的MongoDB实例做组成的集群。 复制集是一个集群,它是2台及2台以上的服务器组成,以及复制集成员包括Primary主节点,Secondary从节点和投票节点。 复制集提供了…

人工智能轨道交通行业周刊-第63期(2023.10.9-10.15)

本期关键词:一体化智慧列车运行系统、车辆数字化运维管理、智能传感器、PHM、LKJ 1 整理涉及公众号名单 1.1 行业类 RT轨道交通人民铁道世界轨道交通资讯网铁路信号技术交流北京铁路轨道交通网上榜铁路视点ITS World轨道交通联盟VSTR铁路与城市轨道交通RailMetro…

十六、代码校验(5)

本章概要 基准测试 微基准测试JMH 的引入 基准测试 我们应该忘掉微小的效率提升,说的就是这些 97% 的时间做的事:过早的优化是万恶之源。—— Donald Knuth 如果你发现自己正在过早优化的滑坡上,你可能浪费了几个月的时间(如果你雄心勃勃的…

CSDN博客创作者一周年纪念文章

捡起一片枯黄的落叶,拾起一个金色的秋天 ——CSDN博客创作者一周年纪念 一年,12个月,累计8万总阅读量。 一年,四季,累计290个收藏,78个点赞,14个评论数,62个粉丝。 一年&#xff…

进化算法------代码示例

前言 遗传算法就是在一个解空间上,随机的给定一组解,这组解称为父亲种群,通过这组解的交叉,变异,构建出新的解,称为下一代种群,然后在目前已有的所有解中抽取表现好的解组成新的父亲种群&#…