熟悉MySQL和HDFS操作

这篇具有很好参考价值的文章主要介绍了熟悉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()

    mysql 查看hdfs,mysql,数据库,hdfs,大数据

  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()

    mysql 查看hdfs,mysql,数据库,hdfs,大数据

  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()

    mysql 查看hdfs,mysql,数据库,hdfs,大数据

  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()

    mysql 查看hdfs,mysql,数据库,hdfs,大数据

  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()

    mysql 查看hdfs,mysql,数据库,hdfs,大数据

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本地文件系统的某个目录下。文章来源地址https://www.toymoban.com/news/detail-719270.html

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

到了这里,关于熟悉MySQL和HDFS操作的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包