2. 程式人生 > 其它 >華為雲FusionInsight MRS實戰 - Hudi實時入湖之DeltaStreamer工具最佳實踐

華為雲FusionInsight MRS實戰 - Hudi實時入湖之DeltaStreamer工具最佳實踐

阿新 • • 發佈：2022-03-25

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='123456789',
    db='school',
    charset='utf8'
)
# 獲取遊標
cursor = connect.cursor()
# 設定sql語句
sql = "SELECT student.Sno,Sname,Sdept,course.Cno,Cname,Grade " \
      "FROM student,course,sc " \
      "WHERE student.Sno = sc.Sno AND course.Cno = sc.Cno AND sc.Sno = '%s'"
# 設定資料
data = ('10002',)
# 執行sql語句
cursor.execute(sql % data)
# 獲取資料
print("共有%s條記錄" % cursor.rowcount)
for row in cursor.fetchall():
    print("學號：%s\t姓名：%s\t系別：%s\t課程號：%s\t課程名：%s\t成績：%d" % row)
# 關閉資料庫連線
cursor.close()
connect.close()

 

 

 

(2) 查詢每位學生成績大於85的課程，結果中需包含學號、姓名、所在系別、課程號、課程名以及對應成績。

import pymysql.cursors
# 連線資料庫
connect = pymysql.Connect(
    host='localhost',
    port=3306,
    user='root',
    passwd='123456789',
    db='school',
    charset='utf8'
)
# 獲取遊標
cursor = connect.cursor()
# 設定sql語句
sql = "SELECT student.Sno,Sname,Sdept,course.Cno,Cname,Grade " \
      "FROM student,course,sc " \
      "WHERE student.Sno = sc.Sno AND course.Cno = sc.Cno AND Grade > %d"
# 設定資料
data = (85, )
# 執行sql語句
cursor.execute(sql % data)
# 獲取資料
print("共有%s條記錄" % cursor.rowcount)
for row in cursor.fetchall():
    print("學號：%s\t姓名：%s\t系別：%s\t課程號：%s\t課程名：%s\t成績：%d" % row)
# 關閉資料庫連線
cursor.close()
connect.close()

 

(3) 由於培養計劃改，現需將課程號為00001、課程名為DataBase的學分改為5學分。

import pymysql.cursors
# 連線資料庫
connect = pymysql.Connect(
    host='localhost',
    port=3306,
    user='root',
    passwd='123456789',
    db='school',
    charset='utf8'
)
# 獲取遊標
cursor = connect.cursor()
# 設定sql語句
sql = "UPDATE course SET Credit = %d " \
      "WHERE Cno = '%s'"
# 設定資料
data = (5, '00001')
# 執行sql語句，並獲取執行結果
result = cursor.execute(sql % data)
# 提交事務
connect.commit()
# 檢視執行結果
print(result)
# 關閉資料庫連線
cursor.close()
connect.close()

 

(4) 將學號為10005的學生， OperatingSystems(00004)成績為73分這一記錄寫入選課表中。

import pymysql.cursors
# 連線資料庫
connect = pymysql.Connect(
    host='localhost',
    port=3306,
    user='root',
    passwd='123456789',
    db='school',
    charset='utf8'
)
# 獲取遊標
cursor = connect.cursor()
# 設定sql語句
sql = "INSERT INTO sc(Sno,Cno,Grade) VALUES('%s','%s',%d)"
# 設定資料
data = ('10005', '00004', 73)
# 執行sql語句，並獲取執行結果
result = cursor.execute(sql % data)
connect.commit()
# 輸出執行結果
print(result)
# 關閉資料庫連線
cursor.close()
connect.close()

 

(5) 將學號為10003的學生從這三個表中刪除。

import pymysql.cursors
# 連線資料庫
connect = pymysql.Connect(
    host='localhost',
    port=3306,
    user='root',
    passwd='123456789',
    db='school',
    charset='utf8'
)
# 獲取遊標
cursor = connect.cursor()
# 設定sql語句
sql = "DELETE FROM student WHERE Sno = '%s'"
# 設定資料
data = ('10003',)
# 執行sql語句，並獲取執行結果
result = cursor.execute(sql % data)
connect.commit()
# 輸出執行結果
print(result)
# 關閉資料庫連線
cursor.close()
connect.close()

 

相關推薦

華為雲FusionInsight MRS實戰 - Hudi實時入湖之DeltaStreamer工具最佳實踐

背景 傳統大資料平臺的組織架構是針對離線資料處理需求設計的，常用的資料匯入方式為採用sqoop定時作業批量匯入。隨著資料分析對實時性要求不斷提高，按小時、甚至分鐘級的資料同步越來越普遍。由此展開了基於spark/

【技術乾貨】華為雲FusionInsight MRS的自研超級排程器Superior Scheduler

Superior Scheduler是一個專門為Hadoop YARN分散式資源管理系統設計的排程引擎，是針對企業客戶融合資源池，多租戶的業務訴求而設計的高效能企業級排程器。

華為雲FusionInsight MRS HDFS元件資料儲存策略配置指導

操作場景 預設情況下，HDFS NameNode自動選擇DataNode儲存資料的副本。在實際業務中，可能存在以下場景：

華為雲物聯網高階攻城獅的4年配置中心實踐分享

摘要：4年期間經歷了自研配置中心到 Apollo 再到自研配置中心和 Apollo 並存的場景，本文總結了一下這幾年的配置中心演進流程。

華為雲MRS基於Hudi和HetuEngine構建實時資料湖最佳實踐

資料湖與實時資料湖是什麼？ 各個行業企業都在構建企業級資料湖，將企業內多種格式資料來源匯聚的大資料平臺，通過嚴格的資料許可權和資源管控，將資料和算力開放給各種使用者。一份資料支援多種分析，是資料湖最大的

技術解析+程式碼實戰，帶你入門華為雲政務區塊鏈平臺

摘要：政務區塊鏈平臺是行業區塊鏈平臺的初步實踐，未來在區塊鏈技術的發展下，還會打造面向其他領域的鏈管平臺，構建多方協同的分散式賬本，讓區塊鏈應用更便捷高效的為產業服務。

華為雲釋出實時音視訊行業加速器，為企業解決技術與商業雙重難題

摘要：在加速器，企業可以圍繞政企服務、線上醫療、視訊會議、社交娛樂、線上教育和線上金融等場景部署實時音視訊的解決方案。

【譯】華為雲——程式碼質量“多雲”

原文連結 使用靜態程式碼分析看一看華為的原始碼。 出於各種原因，有許多企業進入了雲市場並建立了他們自己的雲服務。最近，我們的團隊致力於將PVS-Studio程式碼分析工具整合到我們的雲架構中。我們的忠實讀者可能已

華為雲—環境安裝(jdk安裝，tomcat安裝)

前言 在前面咱們講到華為雲的購買以及一些配置，通過上一文即可獲得一個可以直接訪問使用的雲伺服器。但是對於不同的人群伺服器的使用用途可能不同，對於咱們大部分的java程式設計師來說，jdk、tomcat、mysql、redis

古有七步成詩，今有六步完成DevOps上華為雲DevCloud實踐

引言： 在“DevOps能力之屋（Capabilities House of DevOps）”中，華為雲DevCloud提出（工程方法+最佳實踐+生態）×工具平臺=DevOps能力。華為雲DevCloud將推出“DevOps on DevCloud”系列

【華為雲技術分享】跟唐老師學習雲網路 ： Kubernetes網路實現

當今K8s獨霸天下之時，咱們站在更高的角度，好好的看看K8s網路是以什麼理念構築的。以及一個容器叢集的好保姆，是如何分別照顧 南北流量和東西流量的。

華為雲MVP熊保鬆談物聯網開發:華為雲IoT是首選，小熊派是神器

摘要：在AI、5G的技術驅動下，物聯網行業的發展愈加如火如荼，開發者在技術的快速更迭間，也得乘風破浪跟上新技術的節奏。

在華為雲上自建聊天平臺遇到的坑（開放埠）

618的時候買了一臺華為雲耀雲伺服器，然後在暑假的時候想要用伺服器做一點事情，想到在學校的時候有一個Java實驗是實現本地的聊天伺服器+聊天客戶端，當時做實驗的時候覺得好神奇，想著有朝一日要把這個簡易的聊天室

一文快速掌握華為雲IPv6基礎知識及使用指南

隨著5G、物聯網等新興技術領域的發展，IP空間需求巨大，IPv6成為萬物互聯的基礎，勢在必行；華為雲作為IPv6成熟商用開拓者，針對金融、廣電、媒資等不同行業推出IPv6解決方案，助力企業平滑升級到IPv6基礎架構。本文

Nagios 呼叫華為雲簡訊平臺進行報警

1.建立 /usr/local/nagios/script/hwc_sms.py \"\"\" @author: @contact: @version: \"\"\" # -*- coding: utf-8 -*-

華為雲ubunbu部署.NetCore3.1專案（DDD商城）

提前專案打包釋出，檔案傳輸工具Filezilla,注意是選擇sftp協議，將publish檔案傳到/home資料夾下

華為雲GaussDB（DWS）記憶體知識點,你知道嗎?

前言 在日常資料庫的使用中，難免會遇到一些記憶體問題。此次博文主要向大家分享一些華為雲數倉GaussDB(DWS)記憶體的基本框架以及基本檢視的使用，以便遇到記憶體問題後可以有一個基本的判斷。

技術貼丨教你使用華為雲鯤鵬伺服器部署Discuz!論壇

摘要：這裡給大家介紹一個簡單的方法,那就是通過華為雲鯤鵬伺服器來建立 discuz!論壇

華為雲線上搭建FTP伺服器(CentOS7.6)

安裝vsftpd 登入伺服器 執行以下命令安裝vsftpd yum install -y vsftpd 回顯如下類似資訊時，表示軟體安裝成功：

華為雲 快取過期 python 指令碼

華為雲 快取過期 python 指令碼 [root@jenkins tools]# cat refreshTask.py # -*- coding:utf-8 -*-