簡單5步,輕鬆debug K8S服務!

作者:
Ram Rai,性能、可擴展性以及軟件架構的愛好者

原文鏈接:
https://medium.com/better-programming/debug-your-kubernetes-service-in-5-easy-steps-1457974f024c

在Kubernetes中,服務是一個核心概念。在本文中,將介紹如何調試K8S服務,這些服務是由多個Pod組成的工作負載的抽象接口(主機+端口)。

在我們深入探索debug方法之前,我們先簡單回顧一下網絡,這是Kubernetes服務的基礎。

  • 在一個pod中的容器共享相同的網絡空間和IP。

  • 所有的pod都能通過IP彼此通信。

  • 每個節點都能看到所有的Pod,反之亦然。

  • Pod可以看到所有的服務。

那麼,在實踐中這些意味着什麼呢?

在圖中:

  • 位於Pod1中的容器B可以直接作為localhost尋址容器A

  • 容器B可以通過其IP直接尋址Pod2(kubectl get pod -o wide)。我們知道當pod2出現故障時着不是一個可靠的通信渠道,並且一個新的pod可以出現在其位置中。但是我們無法追逐不斷變化的目標。

  • 接下來,容器B可以通過Service x訪問pod 2和pod 3,後者將它們的IP與負載均衡捆綁在一起;因此,在K8S上支持基於微服務的應用程序起着至關重要的作用

儘管對Kubernetes的內部網絡結構的檢查不在本文的討論範圍內,但我稍後會發布一些參考資料以供大家進一步研究。

對於當下,我還是鼓勵你花費一點時間在實踐中經歷和理解Kubernetes中的網絡。例如,你可以啟動一個Kubernetes測試pod並且嘗試從該pod中訪問其他pod、節點和服務。此處显示的命令將在Pod內彈出一個Linux shell。

kubectl run -it networktest --image=alpine bin/ash --restart=Never --rm

現在你在Kubernetes網絡空間內並且你可以隨意使用wegtpingnslookup之類的命令進行實驗。例如,測試你的Kubernetes集群中先前列出的網絡要求,nslookup <servicename>, ping <PodIP>

現在讓我們回到我們的話題,troubleshooting Kubernetes服務,這實際上是一種網絡結構。

Step1:檢查服務是否存在

kubectl get svc

如果服務不存在,應該是服務創建出現了故障,因此要去檢查你的服務定義。

Step2:測試你的服務

請記住,一個內部的Kubernetes ClusterIP服務是無法在集群外部訪問的。因此,有兩種方法可以對其進行測試。方法一,你可以啟動一個測試Pod,通過SSH進入該pod,然後嘗試像這樣訪問你的服務:

kubectl run -it testpod --image=alpine bin/ash --restart=Never --rm

在本文中我們啟動一個alpine Docker鏡像作為pod來從其內部測試服務:

#works for http services
wget <servicename>:<httpport>

#Confirm there is a DNS entry for the service!
nslookup <servicename>

或者,你可以轉發到本地計算機並在本地進行測試。

kubectl port-forward <service_name> 8000:8080

現在,你可以通過localhost:8000訪問服務。

Step3:檢查服務是否target相關Pod

Kubernetes服務會根據標籤selector將入站流量路由到其中一個pod,流量通過其IP路由到目標Pod。所以,請檢查服務是否綁定到那些pod。

kubectl describe service <service-name> | grep Endpoints

執行上述命令之後,你應該看到與列出的工作負載相關的所有Pod的IP。如果沒有看到,請執行Step4。

Step4:檢查Pod標籤

確保在Kubernetes服務中的selector與pod的標籤相匹配。

kubectl get pods --show-labels
kubectl describe svc <service_name>

從下面的截圖的中可以看到,pod的標籤在右邊。四個pod被標記為app=tinywebsitetier=frontend,這些標籤與下面“described”的服務selector相匹配。

在這四個匹配的Pod中,只有三個正在運行,其IP在突出显示的行中被列為服務的端點(endpoint)。你還可以在IP列中看到相同的IP。

Step5:確認服務端口與pod相匹配

最後,確保在你的pod中的代碼能夠監聽到你為服務指定的targetPort(例如,你在上方截圖中看到的port8001)!

這十分簡單,為了讓你更進一步深入了解和研究Kubernetes的網絡世界,歡迎你閱讀以下文章。

  • 在Kubernetes中部署一個應用程序

  • Debug服務

  • Kubernetes網絡

本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

網頁設計公司推薦不同的風格,搶佔消費者視覺第一線

※想知道購買電動車哪裡補助最多?台中電動車補助資訊懶人包彙整

南投搬家公司費用,距離,噸數怎麼算?達人教你簡易估價知識!

※教你寫出一流的銷售文案?

※超省錢租車方案

助長毀林?巴西銷往歐洲的黃豆 至少20%來自森林砍伐

環境資訊中心綜合外電;姜唯 編譯;林大利 審校

本站聲明:網站內容來源環境資訊中心https://e-info.org.tw/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※帶您來了解什麼是 USB CONNECTOR  ?

※自行創業缺乏曝光? 網頁設計幫您第一時間規劃公司的形象門面

※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站,提高曝光率!

※綠能、環保無空污,成為電動車最新代名詞,目前市場使用率逐漸普及化

※廣告預算用在刀口上,台北網頁設計公司幫您達到更多曝光效益

※教你寫出一流的銷售文案?

心痛!抹香鯨遭漁網纏住痛苦掙扎 潛水員花3天仍割不完

摘錄自2020年7月22日自由時報報導

義大利當地時間18日,一條抹香鯨在利帕里島(Lipari)附近海域被廢棄漁網纏住,義大利海警花了數天時間企圖割開漁網,但由於抹香鯨躁動,導致進度緩慢。

綜合外媒報導,一隻抹香鯨被發現受困於義大利利帕里島海域,牠被廢棄漁網困住無法游離,義大利海警獲報後,即刻出動潛水員救援,他們企圖割開漁網,但由於抹香鯨情緒不穩,相當躁動,令潛水員相當困擾,也因此把牠命為「Fury」(憤怒之意),潛水員花了3天時間才將部分漁網割下。

不料恢復行動力的「Fury」開始下潛失去蹤影,儘管纏在「Fury」身上的大部分漁網已經割開,不過牠的尾巴仍有魚網纏繞住,救難人員正積極尋找其下落。

生物多樣性
海洋
國際新聞
抹香鯨
漁網

本站聲明:網站內容來源環境資訊中心https://e-info.org.tw/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※為什麼 USB CONNECTOR 是電子產業重要的元件?

網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※台北網頁設計公司全省服務真心推薦

※想知道最厲害的網頁設計公司"嚨底家"!

※推薦評價好的iphone維修中心

東南亞最大湖泊洞里薩湖延遲回流 柬埔寨歸咎上游中、寮大壩

摘錄自2020年7月22日ETtoday新聞雲報導

位於柬埔寨的洞里薩湖(Tonle Sap)是東南亞最大的湖泊,無論旱、雨季都出產大量魚蝦,周圍地帶有約300萬人以漁業相關產業維生。

洞里薩湖的水源—湄公河—通常會於雨季水位上漲,並回流至柬埔寨的洞里薩湖,提供豐富的魚類資源。但專家稱,近來連續2年湄公河都延遲回流,嚴重干擾了捕魚活動,影響上百萬人的糧食供應。

據《路透社》報導,湄公河委員會認為延遲回流現象歸因於2019年降雨減少,以及湄公河上游2座寮國和11座中國水壩的運行,破壞了湄公河的自然水流,回流預計延遲到下個月(8月)才可能發生,導致漁民生計大受影響。

生物多樣性
國際新聞
柬埔寨
洞里薩湖
水源供應
湄公河
大壩
截流
水文

本站聲明:網站內容來源環境資訊中心https://e-info.org.tw/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

USB CONNECTOR掌控什麼技術要點? 帶您認識其相關發展及效能

台北網頁設計公司這麼多該如何選擇?

※智慧手機時代的來臨,RWD網頁設計為架站首選

※評比南投搬家公司費用收費行情懶人包大公開

※回頭車貨運收費標準

Redis學習筆記(十八) 集群(下)

複製和故障轉移

Redis集群中的節點分為主節點(master)和從節點(slave),其中主節點用於處理槽,而從節點則用於複製某個主節點,並在被複制 的主節點下線時,代替下線主節點繼續處理命令請求。

設置從節點:CLUSTER REPLICATE < node_id >可以讓接收命令的節點稱為node_id 所指定節點的從節點,並開始對主節點進行複製。

1)接收到該命令的節點首先會在自己的clusterState.nodes字典中找到node_id所對應節點的clusterNode結構,並將自己的clusterState.myself.slaveof指針指向這個結構,以此來記錄這個節點正在複製的主節點:

struct clusterNode{
    //如果這個時一個從節點,那麼指向主節點
    struct clusterNode *slaveof;
}

2)節點修改自己的clusterState.myself.flags中的屬性,關閉原本的REDIS_NODE_MASTER標識,打開REDIS_NODE_SLAVE標識,標識這個節點已經由原來的主節點變成了從節點。

3)節點會調用複製代碼,根據clusterState.myself.slaveof指向clusterNode結構所保存的IP地址和端口號,對節點進行複製。

一個節點稱為從節點,並開始複製某個主節點這一信息會通過消息發送給集群中的其他節點,最終集群中的所有節點都會知道某個從節點正在複製某個主節點。

集群中的所有節點都會在代表主節點的clusterNode結構的slaves屬性和numslaves屬性中記錄正在複製這個主節點的從節點名單:

struct clusterNode{
    //正在複製這個主節點的從節點數量
    int numslaves;
    //數組,每個數組項指向一個正在複製這個主節點的從節點的clusterNode
    struct clusterNode **slaves;
}

集群中的每個節點都會定期地向集群中的其他節點發送PING消息,一次來檢測對方是否在線,如果接收PING消息的節點沒有在規定的時間內,向發送PING消息的節點返回PONG消息,那麼發送PING消息的節點就會將階段后PING消息的節點標記為疑似下線(PFAIL)。

集群中的各個節點會通過相互發送消息的方式來交換集群中各個節點的狀態信息:某個節點處於在線狀態、疑似下線、已下線狀態。

當一個主節點A通過罅隙得知主節點B認為主節點C進入疑似下線狀態時,主節點A會在自己的clusterState.nodes字典中找到主節點C所對應的clusterNode結構,並將主節點B的下線報告添加到clusterNode結構的fail_reports鏈表中

status clusterNode{
    list *fali_reports;//鏈表,記錄所有其他節點對該節點的下線報告
};

下線報告結構:

 

struct c;isterNodeFailReport{
    //報告目標節點已經下線的節點
    struct clusterNode *node;
    //最後一個從node節點收到下線報告的時間(程序使用這個時間戳來檢查下線報告是否過期)
    mstime_t time;
} typedef clusterNodeFailReport;

如果集群里半數以上負責處理槽的主節點都將某個主節點x報告未疑似下線,那麼這個主節點x將被標記未已下線,將主節點x標記為已下線的節點會向集群廣播一條關於主節點x的FAIL罅隙,所有收到這條罅隙的節點都會立即將主節點x標記為已下線。

故障轉移的步驟:

1)複製下線主節點的所有從節點裏面,會有一個從節點被選中,

2)被選中的從節點會執行SLAVEOF no one命令,成為新的主節點。

3)新的主節點會撤銷所有對已下線主節點的槽指派,並將這些槽指派給自己。

4)新的主節點向集群廣播一條PONG消息,這條消息讓其他集群中的其他節點立即知道這個節點已經由從節點變為主節點,並且這個主節點已經接管了原本已下線節點負責處理的槽。

5)新的主節點開始接收和自己負責處理的槽有關的命令請求,故障轉移完成。

選舉新的主節點:

1)集群的配置紀元是一個計數器。他的初始值為0;

2)當集群中的某個節點開始一次故障轉移操作時,集群配置紀元的值會被加1。

3)集群裏面每個負責處理槽的主節點都有一次投票機會,而第一個向主節點要求投票的從節點將獲得主節點的投票。

4)當從節點發現自己正在複製的主節點進入下線狀態時,從節點會向集群官博一條CLUSTERMSG_TYPE_FAILOVER_AUTH_REQUEST消息,要求所有收到這個消息、並且具有投票權的主節點向這個從節點投票。

5)如果一個主節點具有投票權,並且這個主節點尚未投票給其他從節點,那麼主節點將向要求投票的從節點返回一條CLUSTERMSG_TYPE_FAILOVER_AUTH_ACK消息,表示這個主節點支持從節點成為新的主節點。

6)每個參与選舉的從節點都會收到CLUSTERMSG_TYPE_FAILOVER_AUTH_ACK消息,並根據自己收到了多少條這種消息來統計自己獲得了多少主節點支持。

7)如果集群中有N個具有投票權的主節點,那麼當一個從節點大於等於N/2+1張支持票時,這個從節點就當選成為新的主節點。

8)如果在一個配置紀元裏面沒有從節點收集到足夠多的支持票,那麼集群進入下一個紀元,再次進行選舉,直到選出新的主節點為止。

 

消息

集群中各個節點通過發送和接收消息來進行通信,我們稱發送消息的節點為發送者,接收消息的節點為接收者:

1)MEET消息,當發送者接到客戶端發送的CLUSTER MEET命令時,發送者會向接收者發送MEET消息,請求接收者加入到發送者當前所處的集群裏面。

2)PING消息,集群裏面的每個節點默認每隔一秒鐘就會從已知節點列表中隨機選出五個節點,然後對這五個節點中最長時間沒有發送過PING消息的節點發送PING消息,以此檢測被選中的節點是否在線。除此之外,如果節點A最後一次收到節點B發送的PONG消息的時間,距離當前時間已超過了節點A的cluster-node-timeout選項設置時長的一半,那麼節點A也會向節點B發送PING消息,這可以防止節點A因長時間沒有隨機選中節點B作為PING消息的發送對象而導致節點B的信息更新滯后。

3)PONG消息,當接收者收到發送者發來的MEET消息或者PING時,為了向發送者確認這條MEET、PING消息已到達,接收者會向發送者返回一條PONG消息。另外,一個節點也可以通過向集群發送集群廣播自己的PONG消息來讓集群中的其他節點立即刷新關於這個節點的認識。

4)FAIL消息,當一個主節點A判斷另一個主節點B已經進入FAIL狀態時,節點A會會向集群廣播一條關於節點B的FAIL消息,所有接收到這條消息的節點都會立即將節點B標記為已下線。

5)PUBLISH消息,當節點接收到一個PUBLISH命令時,節點會執行這個命令,並向集群廣播一條PUBLISH消息,所有接收到這條PUBLISH消息的節點都會執行相同的PUBLISH命令。

一條消息由消息頭(header)和消息正文(data組成)

消息頭:

typedef struct {
    //消息的長度(消息頭的長度和消息正文的長度)
    uint32_t totlen;
    //消息的類型
    uint16_t type;
    //消息正文包含的節點信息數量
    //只有發送MEET、PING、PONG這三種Gossip協議消息時使用
    uint16_t count;
    
    //薩松這所處的配置紀元
    uint64_t currentEpoch;
    //如果發送者是一個主節點,那麼這裏面記錄的時發送者的配置紀元
    //如果發送者時一個從節點,那麼這裏面記錄的時發送者正在複製的主節點的配置紀元
    uint64_t configEpoch;
    //發送者的名稱(ID)
    char sender[REDIS_CLUSTER_NAMELEN];
    //發送者目前的槽指派信息
    unsigned char myslots[REDIS_CLUSTER_SLOTS/8];
    //如果發送者是一個從節點,記錄的是發送者正在複製的主節點的名稱
    //如果發送者是一個主節點,那麼這裏記錄的是REDIS_NODE_NULL_NAME
    char slaveof[REDIS_CLUSTER_NAMELEN];
    //發送者的端口號
    uint16_t port;
    //發送者的標識值
    uint16_t flags;
    //發送者所處集群的狀態
    unsigned char state;
    //消息正文
    union clusterMsgData data;
} clusterMsg;

clusterMsg.data 結構:

union clusterMsgData{
    //MEET PING PONG 消息正文
    struct{
        //每條MEET PING PONG消息都包含兩個 clusterMsgDataGossip 結構
        clusterMsgDataGossip gossip[1]
    } ping;
    //FAIL 消息正文
    struct{
        clusterMsgDataFail about;
    } fali;
    
    //PUBLISH消息正文
    struct{
        clusterMsgDataPublish msg;
    } publish;
}

clusterMsgDataGossip結構記錄了選中節點的名字,發送者與被選中節點最後一次發送和接收PING消息和PONG消息的時間戳,被選中節點的IP地址和端口號,以及被選中節點的標識值:

typedef struct {
    //節點的名字
    char nodename[REDIS_CLUSTER_NAMELEN];
    //最後一次向該節點發送PING消息的時間戳
    uint32_t ping_sent;
    //最後一次從該 節點接收到PONG消息的時間戳
    uint32_t pong_received;
    //節點的IP地址
    char ip[16];
    //節點的端口號
    uint16_t port;
    //節點的標識值
    uint16_t flags;
} clusterMsgDataGossip;

每天學一點,總會有收穫。

 

說明:尊重作者知識產權,文中內容參考《Redis設計與實現》,僅在此做學習與大家分享。

 

 

 

本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※帶您來了解什麼是 USB CONNECTOR  ?

※自行創業缺乏曝光? 網頁設計幫您第一時間規劃公司的形象門面

※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站,提高曝光率!

※綠能、環保無空污,成為電動車最新代名詞,目前市場使用率逐漸普及化

※廣告預算用在刀口上,台北網頁設計公司幫您達到更多曝光效益

※教你寫出一流的銷售文案?

【Spring註解驅動開發】使用@Import註解給容器中快速導入一個組件

寫在前面

我們可以將一些bean組件交由Spring管理,並且Spring支持單實例bean和多實例bean。我們自己寫的類,可以通過包掃描+標註註解(@Controller、@Servcie、@Repository、@Component)的形式將其註冊到IOC容器中,如果不是我們自己寫的類,比如,我們在項目中引入了一些第三方的類庫,此時,我們需要將這些第三方類庫中的類註冊到Spring容器中,該怎麼辦呢?此時,我們就可以使用@Bean和@Import註解將這些類快速的導入Spring容器中。接下來,我們來一起探討下如何使用@Import註解給容器中快速導入一個組件。

項目工程源碼已經提交到GitHub:https://github.com/sunshinelyz/spring-annotation

註冊bean的方式

向Spring容器中註冊bean通常有以下幾種方式:

  • 包掃描+標註註解(@Controller、@Servcie、@Repository、@Component),通常用於自己寫的類。
  • @Bean註解,通常用於導入第三方包中的組件。
  • @Import註解,快速向Spring容器中導入組件。

@Import註解概述

Spring 3.0之前,創建Bean可以通過xml配置文件與掃描特定包下面的類來將類注入到Spring IOC容器內。而在Spring 3.0之後提供了JavaConfig的方式,也就是將IOC容器里Bean的元信息以java代碼的方式進行描述。我們可以通過@Configuration與@Bean這兩個註解配合使用來將原來配置在xml文件里的bean通過java代碼的方式進行描述

@Import註解提供了@Bean註解的功能,同時還有xml配置文件里 標籤組織多個分散的xml文件的功能,當然在這裡是組織多個分散的@Configuration

先看一下@Import註解的源碼:

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Import {
    /**
      * {@link Configuration}, {@link ImportSelector}, {@link ImportBeanDefinitionRegistrar}
      * or regular component classes to import.
      */
     Class<?>[] value();
}

從源碼里可以看出@Import可以配合 Configuration , ImportSelector, ImportBeanDefinitionRegistrar 來使用,下面的or表示也可以把Import當成普通的Bean使用。

@Import只允許放到類上面,不能放到方法上。下面我們來看具體的使用方式。

@Import註解的使用方式

@Import註解的三種用法主要包括:

  • 直接填class數組方式
  • ImportSelector方式【重點】
  • ImportBeanDefinitionRegistrar方式

注意:我們先來看第一種方法:直接填class數組的方式,其他的兩種方式我們後面繼續講。

@Import導入組件的簡單示例

沒有使用@Import註解的效果

首先,我們創建一個Department類,這個類是一個空類,沒有成員變量和方法,如下所示。

package io.mykit.spring.plugins.register.bean;

/**
 * @author binghe
 * @version 1.0.0
 * @description 測試@Import註解的bean
 */
public class Department {
}

接下來,我們先在SpringBeanTest類中創建testAnnotationConfig7()方法,輸出Spring容器中所有的bean,來查看是否存在Department類對應的bean實例,以此來判斷Spring容器中是否註冊有Department類對應的bean實例。

@Test
public void testAnnotationConfig7(){
    ApplicationContext context = new AnnotationConfigApplicationContext(PersonConfig2.class);
    String[] names = context.getBeanDefinitionNames();
    Arrays.stream(names).forEach(System.out::println);
}

運行SpringBeanTest類的testAnnotationConfig7()方法,輸出的結果信息如下所示。

org.springframework.context.annotation.internalConfigurationAnnotationProcessor
org.springframework.context.annotation.internalAutowiredAnnotationProcessor
org.springframework.context.annotation.internalCommonAnnotationProcessor
org.springframework.context.event.internalEventListenerProcessor
org.springframework.context.event.internalEventListenerFactory
personConfig2
person
binghe001

可以看到Spring容器中並沒有Department類對應的bean實例。

使用@Import註解的效果

我們在PersonConfig2類上添加@Import註解,並將Department類標註到註解中,如下所示。

@Configuration
@Import(Department.class)
public class PersonConfig2 {

此時,我們再次運行SpringBeanTest類的testAnnotationConfig7()方法,輸出的結果信息如下所示。

org.springframework.context.annotation.internalConfigurationAnnotationProcessor
org.springframework.context.annotation.internalAutowiredAnnotationProcessor
org.springframework.context.annotation.internalCommonAnnotationProcessor
org.springframework.context.event.internalEventListenerProcessor
org.springframework.context.event.internalEventListenerFactory
personConfig2
io.mykit.spring.plugins.register.bean.Department
person
binghe001

可以看到,輸出結果中打印了io.mykit.spring.plugins.register.bean.Department,說明使用@Import導入bean時,id默認是組件的全類名。

@Import註解支持同時導入多個類,例如,我們再次創建一個Employee類,如下所示。

package io.mykit.spring.plugins.register.bean;
/**
 * @author binghe
 * @version 1.0.0
 * @description 測試@Import註解的bean
 */
public class Employee {
}

接下來,我們也將Employee類添加到@Import註解中,如下所示。

@Configuration
@Import({Department.class, Employee.class})
public class PersonConfig2 {

此時,我們再次運行SpringBeanTest類的testAnnotationConfig7()方法,輸出的結果信息如下所示。

org.springframework.context.annotation.internalConfigurationAnnotationProcessor
org.springframework.context.annotation.internalAutowiredAnnotationProcessor
org.springframework.context.annotation.internalCommonAnnotationProcessor
org.springframework.context.event.internalEventListenerProcessor
org.springframework.context.event.internalEventListenerFactory
personConfig2
io.mykit.spring.plugins.register.bean.Department
io.mykit.spring.plugins.register.bean.Employee
person
binghe001

可以看到,結果信息中同時輸出了io.mykit.spring.plugins.register.bean.Department和io.mykit.spring.plugins.register.bean.Employee,說明Department類的bean實例和Employee類的bean實例都導入到Spring容器中了。

好了,咱們今天就聊到這兒吧!別忘了給個在看和轉發,讓更多的人看到,一起學習一起進步!!

項目工程源碼已經提交到GitHub:https://github.com/sunshinelyz/spring-annotation

寫在最後

如果覺得文章對你有點幫助,請微信搜索並關注「 冰河技術 」微信公眾號,跟冰河學習Spring註解驅動開發。公眾號回復“spring註解”關鍵字,領取Spring註解驅動開發核心知識圖,讓Spring註解驅動開發不再迷茫。

本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※為什麼 USB CONNECTOR 是電子產業重要的元件?

網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※台北網頁設計公司全省服務真心推薦

※想知道最厲害的網頁設計公司"嚨底家"!

※推薦評價好的iphone維修中心

面試官突然問我MySQL存儲過程,我竟然連基礎都不會!(詳細)

所有知識體系文章,GitHub已收錄,歡迎Star!再次感謝,願你早日進入大廠!

GitHub地址: https://github.com/Ziphtracks/JavaLearningmanual

MySQL存儲過程

一、存儲過程

1.1 什麼是存儲過程

存儲過程(Stored Procedure)是在大型數據庫系統中,一組為了完成特定功能的SQL 語句集,它存儲在數據庫中,一次編譯后永久有效,用戶通過指定存儲過程的名字並給出參數(如果該存儲過程帶有參數)來執行它。存儲過程是數據庫中的一個重要對象。在數據量特別龐大的情況下利用存儲過程能達到倍速的效率提升

1.2 數據庫存儲過程程序

當我們了了解存儲過程是什麼之後,就需要了解數據庫中存在的這三種類型的數據庫存儲類型程序,如下:

  • 存儲過程: 存儲過程是最常見的存儲程序,存儲過程是能夠接受輸入和輸出參數並且能夠在請求時被執行的程序單元。
  • 存儲函數: 存儲函數和存儲過程很相像,但是它的執行結果會返回一個值。最重要的是存儲函數可以被用來充當標準的 SQL 語句,允許程序員有效的擴展 SQL 語言的能力。
  • 觸發器: 觸發器是用來響應激活或者觸發數據庫行為事件的存儲程序。通常,觸發器用來作為數據庫操作語言的響應而被調用,觸發器可以被用來作為數據校驗和自動反向格式化。

注意: 其他的數據庫提供了別的數據存儲程序,包括包和類。目前MySQL不提供這種結構。

1.3 為什麼要使用存儲程序

雖然目前的開發中存儲程序我們使用的並不是很多,但是不一定就否認它。其實存儲程序會為我們使用和管理數據庫帶來了很多優勢:

  • 使用存儲程序更加安全。
  • 存儲程序提供了一種數據訪問的抽象機制,它能夠極大的改善你的代碼在底層數據結構演化過程中的易維護性。
  • 存儲程序可以降低網絡擁阻,因為屬於數據庫服務器的內部數據,這相比在網上傳輸數據要快的多。
  • 存儲程序可以替多種使用不同構架的外圍應用實現共享的訪問例程,無論這些構架是基於數據庫服務器外部還是內部。
  • 以數據為中心的邏輯可以被獨立的放置於存儲程序中,這樣可以為程序員帶來更高、更為獨特的數據庫編程體驗。
  • 在某些情況下,使用存儲程序可以改善應用程序的可移植性。(在另外某些情況下,可移植性也會很差!)

這裏我大致解釋一下上述幾種使用存儲程序的優勢:

我們要知道在Java語言中,我們使用數據庫與Java代碼結合持久化存儲需要引入JDBC來完成。會想到JDBC,我們是否還能想起SQL注入問題呢?雖然使用PreparedStatement解決SQL注入問題,那就真的是絕對安全嗎?不,它不是絕對安全的。

這時候分析一下數據庫與Java代碼的連接操作流程。在BS結構中,一般都是瀏覽器訪問服務器的,再由服務器發送SQL語句到數據庫,在數據庫中對SQL語句進行編譯運行,最後把結果通過服務器處理再返回瀏覽器。在此操作過程中,瀏覽器對服務器每發送一次對數據庫操作的請求就會調用對應的SQL語句編譯和執行,這是一件十分浪費性能的事情,性能下降 了就說明對數據庫的操作效率低 了。

還有一種可能是,在這個過程中進行發送傳輸的SQL語句是對真實的庫表進行操作的SQL語句,如果在發送傳輸的過程中被攔截了,一些不法分子會根據他所攔截的SQL語句推斷出我們數據庫中的庫表結構,這是一個很大的安全隱患

關於可維護性的提高,這裏模擬一個場景。通常數據庫在公司中是由DBA來管理的,如果管理數據庫多年的DBA辭職了,此時數據庫會被下一任DBA來管理。這裏時候問題來了,數據庫中這麼多的數據和SQL語句顯然對下一任管理者不太友好。就算管理多年的DBA長時間不操作查看數據庫也會忘記點什麼東西。所以,我們在需要引入存儲程序來進行SQL語句的統一編寫和編譯,為維護提供了便利 。(其實我覺得這個例子並不生動合理,但是為了大家能理解,請體諒!)

講了很多存儲程序的優勢演變過程,其核心就是: 需要將編譯好的一段或多段SQL語句放置在數據庫端的存儲程序中,以便解決以上問題並方便開發者直接調用。

二、存儲過程的使用步驟

2.1 存儲過程的開發思想

存儲過程時數據庫的一個重要的對象,可以封裝SQL語句集,可以用來完成一些較複雜的業務邏輯,並且可以入參(傳參)、出參(返回參數),這裏與Java中封裝方式十分相似。

而且創建時會預先編譯后保存,開發者後續的調用都不需要再次編譯。

2.2 存儲過程的優缺點

存儲過程使用的優缺點其實在1.3中的優勢中說到了。這裏我簡單羅列一下存儲過程的優點與缺點。

  • 優點:
  • 在生產環境下,可以通過直接修改存儲過程的方式修改業務邏輯或bug,而不用重啟服務器。
  • 執行速度快,存儲過程經過編譯之後會比單獨一條一條編譯執行要快很多。
  • 減少網絡傳輸流量。
  • 便於開發者或DBA使用和維護。
  • 在相同數據庫語法的情況下,改善了可移植性。
  • 缺點:
  • 過程化編程,複雜業務處理的維護成本高。
  • 調試不便。
  • 因為不同數據庫語法不一致,不同數據庫之間可移植性差。

2.3 MySQL存儲過程的官方文檔

英語好或者有能力的小夥伴可以去參考一下官方文檔。如果不參考官方文檔,沒關係,我在下面也會詳細講述MySQL存儲過程的各個知識點。

1https://dev.mysql.com/doc/refman/5.6/en/preface.html

2.3 存儲過程的使用語法

1create PROCEDURE 過程名( in|out|inout 參數名 數據類型 , ...)
2begin
3    sql語句;
4end;
5call 過程名(參數值);

in是定義傳入參數的關鍵字。out是定義出參的關鍵字。inout是定義一個出入參數都可以的參數。如果括號內什麼都不定義,就說明該存儲過程時一個無參的函數。在後面會有詳細的案例分析。

注意: SQL語句默認的結束符為;,所以在使用以上存儲過程時,會報1064的語法錯誤。我們可以使用DELIMITER關鍵字臨時聲明修改SQL語句的結束符為//,如下:

1-- 臨時定義結束符為"//"
2DELIMITER //
3create PROCEDURE 過程名( in|out 參數名 數據類型 , ...)
4begin
5    sql語句;
6end//
7-- 將結束符重新定義回結束符為";"
8DELIMITER ;

例如: 使用存儲過程來查詢員工的工資(無參)

注意: 如果在特殊的必要情況下,我們還可以通過delimiter關鍵字將;結束符聲明回來使用,在以下案例中我並沒有這樣將結束符聲明回原來的;,在此請大家注意~

為什麼我在這裏提供了drop(刪除)呢?

是因為我們在使用的時候如果需要修改存儲過程中的內容,我們需要先刪除現有的存儲過程后,再creat重新創建。

 1# 聲明結束符為//
2delimiter //
3
4# 創建存儲過程(函數)
5create procedure se()
6begin
7    select salary from employee;
8end //
9
10# 調用函數
11call se() //
12
13# 刪除已存在存儲過程——se()函數
14drop procedure if exists se //

三、存儲過程的變量和賦值

3.1 局部變量

聲明局部變量語法: declare var_name type [default var_value];

賦值語法:

注意: 局部變量的定義,在begin/end塊中有效。

使用set為參數賦值

 1# set賦值
2
3# 聲明結束符為//
4delimiter //
5
6# 創建存儲過程
7create procedure val_set()
8begin
9    # 聲明一個默認值為unknown的val_name局部變量
10    declare val_name varchar(32) default 'unknown'
;
11    # 為局部變量賦值
12    set val_name = 'Centi';
13    # 查詢局部變量
14    select val_name;
15end //
16
17# 調用函數
18call val_set() //
19

使用into接收參數

 1delimiter //
2create procedure val_into()
3begin
4    # 定義兩個變量存放name和age
5    declare val_name varchar(32) default 'unknown'
;
6    declare val_age int;
7    # 查詢表中id為1的name和age並放在定義的兩個變量中
8    select name,age into val_name,val_age from employee where id = 1;
9    # 查詢兩個變量
10    select val_name,val_age;
11end //
12
13call val_into() //
14

3.2 用戶變量

用戶自定義用戶變量,當前會話(連接)有效。與Java中的成員變量相似。

  • 語法: @val_name
  • 注意: 該用戶變量不需要提前聲明,使用即為聲明。
 1delimiter //
2create procedure val_user()
3begin
4    # 為用戶變量賦值
5    set @val_name = 'Lacy';
6end //
7
8# 調用函數
9call val_user() //
10
11# 查詢該用戶變量
12select @val_name //

3.3 會話變量

會話變量是由系統提供的,只在當前會話(連接)中有效。

語法: @@session.val_name

1# 查看所有會話變量
2show session variables;
3# 查看指定的會話變量
4select @@session.val_name;
5# 修改指定的會話變量
6set @@session.val_name = 0;

這裏我獲取了一下所有的會話變量,大概有500條會話變量的記錄。等我們深入學習MySQL后,了解了各個會話變量值的作用,可以根據需求和場景來修改會話變量值。

1delimiter //
2create procedure val_session()
3begin
4    # 查看會話變量
5    show session variables
;
6end //
7
8call val_session() //
9

image-20200610112512964

3.4 全局變量

全局變量由系統提供,整個MySQL服務器內有效。

語法: @@global.val_name

1# 查看全局變量中變量名有char的記錄
2show global variables like '%char%' //
3# 查看全局變量character_set_client的值
4select @@global.character_set_client //

3.5 入參出參

入參出參的語法我們在文章開頭已經提過了,但是沒有演示,在這裏我將演示一下入參出參的使用。

語法: in|out|inout 參數名 數據類型 , ...

in定義出參;out定義入參;inout定義出參和入參。

出參in

使用出參in時,就是需要我們傳入參數,在這裏可以對參入的參數加以改變。簡單來說in只負責傳入參數到存儲過程中,類似Java中的形參。

 1delimiter //
2create procedure val_in(in val_name varchar(32))
3begin
4    # 使用用戶變量出參(為用戶變量賦參數值)
5    set @val_name1 = val_name;
6end //
7
8# 調用函數
9call val_in('DK') //
10
11# 查詢該用戶變量
12select @val_name1 //

入參out

在使用out時,需要傳入一個參數。而這個參數相當於是返回值,可以通過調用、接收來獲取這個參數的內容。簡單來說out只負責作返回值。

 1delimiter //
2# 創建一個入參和出參的存儲過程
3create procedure val_out(in val_id int,out val_name varchar(32))
4begin
5    # 傳入參數val_id查詢員工返回name值(查詢出的name值用出參接收並返回)
6    select name into val_name from employee where id = val_id;
7end //
8
9# 調用函數傳入參數並聲明傳入一個用戶變量
10call val_out(1, @n) //
11
12# 查詢用戶變量
13select @n //

入參出參inout

inout關鍵字,就是把in和out合併成了一個關鍵字使用。被關鍵字修飾的參數既可以出參也可以入參。

 1delimiter //
2create procedure val_inout(in val_name varchar(32), inout val_age int)
3begin
4    # 聲明一個a變量
5    declare a int;
6    # 將傳入的參數賦值給a變量
7    set a = val_age;
8    # 通過name查詢age並返回val_age
9    select age into val_age from employee where name = val_name;
10    # 將傳入的a與-和查詢age結果字符串做拼接並查詢出來(concat——拼接字符串)
11    select concat(a, '-', val_age);
12end //
13
14# 聲明一個用戶變量並賦予參數為40
15set @ages = '40' //
16# 調用函數並傳入參數值
17call val_inout('Ziph', @ages) //
18# 執行結果
19# 40-18

四、存儲過程中的流程控制

4.1 if 條件判斷(推薦)

擴展: timestampdiff(unit, exp1, exp2)為exp2 – exp1得到的差值,而單位是unit。(常用於日期)

擴展例子: select timestampdiff(year,’2020-6-6‘,now()) from emp e where id = 1;

解釋擴展例子: 查詢員工表中id為1員工的年齡,exp2就可以為該員工的出生年月日,並以年為單位計算。

語法:

1IF 條件判斷 THEN 結果
2    [ELSEIF 條件判斷 THEN 結果] ...
3    [ELSE 結果]
4END IF

舉例: 傳入所查詢的id參數查詢工資標準(s<=6000為低工資標準;6000 =15000為高工資標準)

 1delimiter //
2create procedure s_sql(in val_id int)
3begin
4    # 聲明一個局部變量result存放工資標準結果
5    declare result varchar(32)
;
6    # 聲明一個局部變量存放查詢得到的工資
7    declare s double;
8    # 根據入參id查詢工資
9    select salary into s from employee where id = val_id;
10    # if判斷的使用
11    if s <= 6000 then
12        set result = '低工資標準';
13    elseif s <= 10000 then
14        set result = '中工資標準';
15    elseif s <= 15000 then
16        set result = '中上工資標準';
17    else
18        set result = '高工資標準';
19    end if;
20    # 查詢工資標準結果
21    select result;
22end //
23
24# 調用函數,傳入參數
25call s_sql(1);

4.2 case條件判斷

關於case語句,不僅僅在存儲過程中可以使用,MySQL基礎查詢語句中也有用到過。相當於是Java中的switch語句。

語法:

 1# 語法一
2CASE case_value
3    WHEN when_value THEN 結果
4    [WHEN when_value THEN 結果] ...
5    [ELSE 結果]
6END CASE
7
8# 語法二(推薦語法)
9CASE
10    WHEN 條件判斷 THEN 結果
11    [WHEN 條件判斷 THEN 結果] ...
12    [ELSE 結果]
13END CASE

舉例:

 1# 語法一
2delimiter //
3create procedure s_case(in val_id int)
4begin
5    # 聲明一個局部變量result存放工資標準結果
6    declare result varchar(32);
7    # 聲明一個局部變量存放查詢得到的工資
8    declare s double;
9    # 根據入參id查詢工資
10    select salary into s from employee where id = val_id;
11    case s
12        when 6000 then set result = '低工資標準';
13        when 10000 then set result = '中工資標準';
14        when 15000 then set result = '中上工資標準';
15        else set result = '高工資標準';
16    end case;
17    select result;
18end //
19
20call s_case(1);
21
22# 語法二(推薦)
23delimiter //
24create procedure s_case(in val_id int)
25begin
26    # 聲明一個局部變量result存放工資標準結果
27    declare result varchar(32);
28    # 聲明一個局部變量存放查詢得到的工資
29    declare s double;
30    # 根據入參id查詢工資
31    select salary into s from employee where id = val_id;
32    case
33        when s <= 6000 then set result = '低工資標準';
34        when s <= 10000 then set result = '中工資標準';
35        when s <= 15000 then set result = '中上工資標準';
36        else set result = '高工資標準';
37    end case;
38    select result;
39end //
40
41call s_case(1);

4.3 loop循環

loop為死循環,需要手動退出循環,我們可以使用leave來退出循環

可以把leave看成Java中的break;與之對應的,就有iterate(繼續循環)也可以看成Java的continue

語法:

1[別名:] LOOP
2    循環語句
3END LOOP [別名]

注意:別名和別名控制的是同一個標籤。

示例1: 循環打印1~10(leave控制循環的退出)

注意:該loop循環為死循環,我們查的1~10数字是i,在死循環中設置了當大於等於10時停止循環,也就是說先後執行了10次該循環內的內容,結果查詢了10次,生成了10個結果(1~10)。

 1delimiter //
2create procedure s_loop()
3begin
4    # 聲明計數器
5    declare i int default 1;
6    # 開始循環
7    num:
8    loop
9        # 查詢計數器記錄的值
10        select i;
11        # 判斷大於等於停止計數
12        if i >= 10 then
13            leave num;
14        end if;
15        # 計數器自增1
16        set i = i + 1;
17    # 結束循環
18    end loop num;
19end //
20
21call s_loop();

打印結果:

image-20200610191639524

示例2: 循環打印1~10(iterate和leave控制循環)

注意:這裏我們使用字符串拼接計數器結果,而條件如果用iterate就必須時 i < 10 了!

 1delimiter //
2create procedure s_loop1()
3begin
4    # 聲明變量i計數器
5    declare i int default 1
;
6    # 聲明字符串容器
7    declare str varchar(256) default '1';
8    # 開始循環
9    num:
10    loop
11        # 計數器自增1
12        set i = i + 1;
13        # 字符串容器拼接計數器結果
14        set str = concat(str, '-', i);
15        # 計數器i如果小於10就繼續執行
16        if i < 10 then
17            iterate num;
18        end if;
19        # 計數器i如果大於10就停止循環
20        leave num;
21    # 停止循環
22    end loop num;
23    # 查詢字符串容器的拼接結果
24    select str;
25end //
26
27call s_loop1();

image-20200610193153512

4.4 repeat循環

repeat循環類似Java中的do while循環,直到條件不滿足才會結束循環。

語法:

1[別名:] REPEAT
2    循環語句
3UNTIL 條件
4END REPEAT [別名]

示例: 循環打印1~10

 1delimiter //
2create procedure s_repeat()
3begin
4    declare i int default 1;
5    declare str varchar(256default '1';
6    # 開始repeat循環
7    num:
8    repeat
9        set i = i + 1;
10        set str = concat(str'-', i);
11    # until 結束條件
12    # end repeat 結束num 結束repeat循環
13    until i >= 10 end repeat num;
14    # 查詢字符串拼接結果
15    select str;
16end //
17
18call s_repeat();

4.5 while循環

while循環就與Java中的while循環很相似了。

語法:

1[別名] WHILE 條件 DO
2    循環語句
3END WHILE [別名]

示例: 循環打印1~10

 1delimiter //
2create procedure s_while()
3begin
4    declare i int default 1;
5    declare str varchar(256default '1';
6    # 開始while循環
7    num:
8    # 指定while循環結束條件
9    while i < 10 do
10        set i = i + 1;
11        set str = concat(str'+', i);
12    # while循環結束
13    end while num;
14    # 查詢while循環拼接字符串
15    select str;
16end //
17
18call s_while();

4.6 流程控制語句(繼續、結束)

至於流程控制的繼續和結束,我們在前面已經使用過了。這裏再列舉一下。

leave:與Java中break;相似

1leave 標籤;

iterate:與Java中的continue;相似

1iterate 標籤;

五、游標與handler

5.1 游標

游標是可以得到某一個結果集並逐行處理數據。游標的逐行操作,導致了游標很少被使用!

語法:

1DECLARE 游標名 CURSOR FOR 查詢語句
2-- 打開語法
3OPEN 游標名
4-- 取值語法
5FETCH 游標名 INTO var_name [, var_name] ...
6-- 關閉語法
7CLOSE 游標名

了解了游標的語法,我們開始使用游標。如下:

示例: 使用游標查詢id、name和salary。

 1delimiter //
2create procedure f()
3begin
4    declare val_id int;
5    declare val_name varchar(32);
6    declare val_salary double;
7
8    # 聲明游標
9    declare emp_flag cursor for
10    select idname, salary from employee;
11
12    # 打開
13    open emp_flag;
14
15    # 取值
16    fetch emp_flag into val_id, val_name, val_salary;
17
18    # 關閉
19    close emp_flag;
20
21    select val_id, val_name, val_salary;
22end //
23
24call f();

執行結果:

image-20200610203622749

因為游標逐行操作的特點,導致我們只能使用游標來查詢一行記錄。怎麼改善代碼才可以實現查詢所有記錄呢?聰明的小夥伴想到了使用循環。對,我們試試使用一下循環。

 1delimiter //
2create procedure f()
3begin
4    declare val_id int;
5    declare val_name varchar(32);
6    declare val_salary double;
7
8    # 聲明游標
9    declare emp_flag cursor for
10    select idname, salary from employee;
11
12    # 打開
13    open emp_flag;
14
15    # 使用循環取值
16    c:loop
17        # 取值
18        fetch emp_flag into val_id, val_name, val_salary;
19    end loop;
20
21    # 關閉
22    close emp_flag;
23
24    select val_id, val_name, val_salary;
25end //
26
27call f();

image-20200610204034224

我們使用循環之後,發現有一個問題,因為循環是死循環,我們不加結束循環的條件,游標會一直查詢記錄,當查到沒有的記錄的時候,就會拋出異常1329:未獲取到選擇處理的行數

如果我們想辦法指定結束循環的條件該怎麼做呢?

這時候可以聲明一個boolean類型的標記。如果為true時則查詢結果集,為false時則結束循環。

 1delimiter //
2create procedure f()
3begin
4    declare val_id int;
5    declare val_name varchar(32);
6    declare val_salary double;
7
8    # 聲明flag標記
9    declare flag boolean default true;
10
11    # 聲明游標
12    declare emp_flag cursor for
13    select idname, salary from employee;
14
15    # 打開
16    open emp_flag;
17
18    # 使用循環取值
19    c:loop
20        fetch emp_flag into val_id, val_name, val_salary;
21        # 如果標記為true則查詢結果集
22        if flag then
23            select val_id, val_name, val_salary;
24        # 如果標記為false則證明結果集查詢完畢,停止死循環
25        else
26            leave c;
27        end if;
28    end loop;
29
30    # 關閉
31    close emp_flag;
32
33    select val_id, val_name, val_salary;
34end //
35
36call f();

上述代碼你會發現並沒有寫完,它留下了一個很嚴肅的問題。當flag = false時候可以結束循環。但是什麼時候才讓flag為false啊?

於是,MySQL為我們提供了一個handler句柄。它可以幫我們解決此疑惑。

handler句柄語法: declare continue handler for 異常 set flag = false;

handler句柄可以用來捕獲異常,也就是說在這個場景中當捕獲到1329:未獲取到選擇處理的行數時,就將flag標記的值改為false。這樣使用handler句柄就解決了結束循環的難題。讓我們來試試吧!

終極版示例: 解決了多行查詢以及結束循環問題。

 1delimiter //
2create procedure f()
3begin
4    declare val_id int;
5    declare val_name varchar(32);
6    declare val_salary double;
7
8    # 聲明flag標記
9    declare flag boolean default true;
10
11    # 聲明游標
12    declare emp_flag cursor for
13    select idname, salary from employee;
14
15    # 使用handler句柄來解決結束循環問題
16    declare continue handler for 1329 set flag = false;
17
18    # 打開
19    open emp_flag;
20
21    # 使用循環取值
22    c:loop
23        fetch emp_flag into val_id, val_name, val_salary;
24        # 如果標記為true則查詢結果集
25        if flag then
26            select val_id, val_name, val_salary;
27        # 如果標記為false則證明結果集查詢完畢,停止死循環
28        else
29            leave c;
30        end if;
31    end loop;
32
33    # 關閉
34    close emp_flag;
35
36    select val_id, val_name, val_salary;
37end //
38
39call f();

執行結果:

image-20200610210925964

在執行結果中,可以看出查詢結果以多次查詢的形式,分佈显示到了每一個查詢結果窗口中。

注意: 在語法中,變量聲明、游標聲明、handler聲明是必須按照先後順序書寫的,否則創建存儲過程出錯。

5.2 handler句柄

語法:

1DECLARE handler操作 HANDLER
2    FOR 情況列表...(比如:異常錯誤情況)
3    操作語句

注意:異常情況可以寫異常錯誤碼、異常別名或SQLSTATE碼。

handler操作:

  • CONTINUE: 繼續
  • EXIT: 退出
  • UNDO: 撤銷

異常情況列表:

  • mysql_error_code
  • SQLSTATE [VALUE] sqlstate_value
  • condition_name
  • SQLWARNING
  • NOT FOUND
  • SQLEXCEPTION

注意: MySQL中各種異常情況代碼、錯誤碼、別名和SQLSTATEM碼可參考官方文檔:

https://dev.mysql.com/doc/refman/5.6/en/server-error-reference.html

寫法示例:

1    DECLARE exit HANDLER FOR SQLSTATE '3D000' set flag = false;
2    DECLARE continue HANDLER FOR 1050 set flag = false;
3    DECLARE continue HANDLER FOR not found set flag = false;

六、循環創建表

需求: 創建下個月的每天對應的表,創建的表格式為:comp_2020_06_01、comp_2020_06_02、...

描述: 我們需要用某個表記錄很多數據,比如記錄某某用戶的搜索、購買行為(注意,此處是假設用數據庫保存),當每天記錄較多時,如果把所有數據都記錄到一張表中太龐大,需要分表,我們的要求是,每天一張表,存當天的統計數據,就要求提前生產這些表——每月月底創建下一個月每天的表!

預編譯: PREPARE 數據庫對象名 FROM 參數名

執行: EXECUTE 數據庫對象名 [USING @var_name [, @var_name] ...]

通過數據庫對象創建或刪除表: {DEALLOCATE | DROP} PREPARE 數據庫對象名

關於時間處理的語句:

1-- EXTRACT(unit FROM date)               截取時間的指定位置值
2-- DATE_ADD(date,INTERVAL expr unit)     日期運算
3-- LAST_DAY(date)                          獲取日期的最後一天
4-- YEAR(date)                             返回日期中的年
5-- MONTH(date)                            返回日期的月
6-- DAYOFMONTH(date)                        返回日

代碼:

 1-- 思路:循環構建表名 comp_2020_06_01 到 comp_2020_06_30;並執行create語句。
2delimiter //
3create procedure sp_create_table()
4begin
5    # 聲明需要拼接表名的下一個月的年、月、日
6    declare next_year int;
7    declare next_month int;
8    declare next_month_day int;
9
10    # 聲明下一個月的月和日的字符串
11    declare next_month_str char(2);
12    declare next_month_day_str char(2);
13
14    # 聲明需要處理每天的表名
15    declare table_name_str char(10);
16
17    # 聲明需要拼接的1
18    declare t_index int default 1;
19    # declare create_table_sql varchar(200);
20
21    # 獲取下個月的年份
22    set next_year = year(date_add(now(),INTERVAL 1 month));
23    # 獲取下個月是幾月 
24    set next_month = month(date_add(now(),INTERVAL 1 month));
25    # 下個月最後一天是幾號
26    set next_month_day = dayofmonth(LAST_DAY(date_add(now(),INTERVAL 1 month)));
27
28    # 如果下一個月月份小於10,就在月份的前面拼接一個0
29    if next_month < 10
30        then set next_month_str = concat('0',next_month);
31    else
32        # 如果月份大於10,不做任何操作
33        set next_month_str = concat('',next_month);
34    end if;
35
36    # 循環操作(下個月的日大於等於1循環開始循環)
37    while t_index <= next_month_day do
38
39        # 如果t_index小於10就在前面拼接0
40        if (t_index < 10)
41            then set next_month_day_str = concat('0',t_index);
42        else
43            # 如果t_index大於10不做任何操作
44            set next_month_day_str = concat('',t_index);
45        end if;
46
47        # 拼接標命字符串
48        set table_name_str = concat(next_year,'_',next_month_str,'_',next_month_day_str);
49        # 拼接create sql語句
50        set @create_table_sql = concat(
51                    'create table comp_',
52                    table_name_str,
53                    '(`grade` INT(11) NULL,`losal` INT(11) NULL,`hisal` INT(11) NULL) COLLATE=\'utf8_general_ci\' ENGINE=InnoDB');
54        # 預編譯
55        # 注意:FROM後面不能使用局部變量!
56        prepare create_table_stmt FROM @create_table_sql;
57        # 執行
58        execute create_table_stmt;
59        # 創建表
60        DEALLOCATE prepare create_table_stmt;
61
62        # t_index自增1
63        set t_index = t_index + 1;
64
65    end while;  
66end//
67
68# 調用函數
69call sp_create_table()

七、其他

7.1 characteristic

在MySQL存儲過程中,如果沒有显示的定義characteristic,它會隱式的定義一系列特性的默認值來創建存儲過程。

  • LANGUAGE SQL

  • 存儲過程語言,默認是sql,說明存儲過程中使用的是sql語言編寫的,暫時只支持sql,後續可能會支持其他語言

  • NOT DETERMINISTIC

  • 是否確定性的輸入就是確定性的輸出,默認是NOT DETERMINISTIC,只對於同樣的輸入,輸出也是一樣的,當前這個值還沒有使用

  • CONTAINS SQL

  • 提供子程序使用數據的內在信息,這些特徵值目前提供給服務器,並沒有根據這些特徵值來約束過程實際使用數據的情況。有以下選擇:

    • CONTAINS SQL表示子程序不包含讀或者寫數據的語句
    • NO SQL 表示子程序不包含sql
    • READS SQL DATA 表示子程序包含讀數據的語句,但是不包含寫數據的語句
    • MODIFIES SQL DATA 表示子程序包含寫數據的語句。
  • SQL SECURITY DEFINER

  • MySQL存儲過程是通過指定SQL SECURITY子句指定執行存儲過程的實際用戶。所以次值用來指定存儲過程是使用創建者的許可來執行,還是執行者的許可來執行,默認值是DEFINER

    • DEFINER 創建者的身份來調用,對於當前用戶來說:如果執行存儲過程的權限,且創建者有訪問表的權限,當前用戶可以成功執行過程的調用的
    • INVOKER 調用者的身份來執行,對於當前用戶來說:如果執行存儲過程的權限,以當前身份去訪問表,如果當前身份沒有訪問表的權限,即便是有執行過程的權限,仍然是無法成功執行過程的調用的。
  • COMMENT ”

  • 存儲過程的註釋性信息寫在COMMENT裏面,這裏只能是單行文本,多行文本會被移除到回車換行等

7.2 死循環處理

如有死循環處理,可以通過下面的命令查看並殺死(結束)

1show processlist;
2kill id;

7.3 select語句中書寫case

1select 
2    case
3        when 條件判斷 then 結果
4        when 條件判斷 then 結果
5        else 結果
6    end 別名,
7    *
8from 表名;

7.4 複製表和數據

1CREATE TABLE dept SELECT * FROM procedure_demo.dept;
2CREATE TABLE emp SELECT * FROM procedure_demo.emp;
3CREATE TABLE salgrade SELECT * FROM procedure_demo.salgrade;

7.5 臨時表

 1create temporary table 表名(
2  字段名 類型 [約束],
3  name varchar(20
4)Engine=InnoDB default charset utf8;
5
6-- 需求:按照部門名稱查詢員工,通過select查看員工的編號、姓名、薪資。(注意,此處僅僅演示游標用法)
7delimiter $$
8create procedure sp_create_table02(in dept_name varchar(32))
9begin
10    declare emp_no int;
11    declare emp_name varchar(32);
12    declare emp_sal decimal(7,2);
13    declare exit_flag int default 0;
14
15    declare emp_cursor cursor for
16        select e.empno,e.ename,e.sal
17        from emp e inner join dept d on e.deptno = d.deptno where d.dname = dept_name;
18
19    declare continue handler for not found set exit_flag = 1;
20
21    -- 創建臨時表收集數據
22    CREATE temporary TABLE `temp_table_emp` (
23        `empno` INT(11NOT NULL COMMENT '員工編號',
24        `ename` VARCHAR(32NULL COMMENT '員工姓名' COLLATE 'utf8_general_ci',
25        `sal` DECIMAL(7,2NOT NULL DEFAULT '0.00' COMMENT '薪資',
26        PRIMARY KEY (`empno`USING BTREE
27    )
28    COLLATE='utf8_general_ci'
29    ENGINE=InnoDB;  
30
31    open emp_cursor;
32
33    c_loop:loop
34        fetch emp_cursor into emp_no,emp_name,emp_sal;
35
36
37        if exit_flag != 1 then
38            insert into temp_table_emp values(emp_no,emp_name,emp_sal); 
39        else
40            leave c_loop;
41        end if;
42
43    end loop c_loop;
44
45    select * from temp_table_emp;
46
47    select @sex_res; -- 僅僅是看一下會不會執行到
48    close emp_cursor;
49
50end$$
51
52call sp_create_table02('RESEARCH');

本站聲明:網站內容來源於博客園,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

USB CONNECTOR掌控什麼技術要點? 帶您認識其相關發展及效能

台北網頁設計公司這麼多該如何選擇?

※智慧手機時代的來臨,RWD網頁設計為架站首選

※評比南投搬家公司費用收費行情懶人包大公開

※回頭車貨運收費標準

10萬以下產品力最強的兩款SUV!詳解風神AX5和遠景SUV!

未來肯定不能以價格取勝。那麼要考慮的就是要從質量與技術可靠為主了。而且有了AX7在前面擋着,未來AX5隻要在宣傳上做得出色,未來還是可以期待的。而遠景SUV換裝了全新的家族式造型設計,與吉利汽車其他車型有了很好的延續性。

目前SUV市場非常紅火,但對於國內的消費者來說;他們很多時候對SUV的購車預算大多數會考慮在10萬以下的車型,而這個區間最火熱的要屬最火熱的遠景SUV了。遠景SUV作為一款上市多年的車型,憑藉著良好的口碑與超高的性價比在三四線城市當中一直都受到追捧。其他品牌看它這麼紅火,肯定心有不甘;醞釀着推出競品與其競爭。在這個背景下,東風風神AX5應該是與它最接近的一款車型了。

總結:AX5作為市場的新丁,未來要遇到的挑戰很多;首先它目前的市場肯可度比較一般,而且相對性價比較高的遠景SUV來說,價格相對高一些;未來肯定不能以價格取勝。那麼要考慮的就是要從質量與技術可靠為主了;而且有了AX7在前面擋着,未來AX5隻要在宣傳上做得出色,未來還是可以期待的。

而遠景SUV換裝了全新的家族式造型設計,與吉利汽車其他車型有了很好的延續性。但它的車尾卻與前臉不太協調,但改款之後提價的策略也被不少消費者詬病;這是吉利急需要改變的不好影響。當然目前吉利汽車一系列熱門車型會把整個市場口碑營造上去,但遠景SUV卻不能以此為傲。雖不說前有前敵,但肯定後邊會有不少追兵。本站聲明:網站內容來源於http://www.auto6s.com/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※帶您來了解什麼是 USB CONNECTOR  ?

※自行創業缺乏曝光? 網頁設計幫您第一時間規劃公司的形象門面

※如何讓商品強力曝光呢? 網頁設計公司幫您建置最吸引人的網站,提高曝光率!

※綠能、環保無空污,成為電動車最新代名詞,目前市場使用率逐漸普及化

※廣告預算用在刀口上,台北網頁設計公司幫您達到更多曝光效益

※教你寫出一流的銷售文案?

不到15萬,軸距超過3米還有誰!

而依維柯的中控 則採用了深灰色的內飾配色,整體看起來略微有些沉悶。並且空調的出風口以及手套箱的設計相對過於緊湊,讓人感覺整个中控台略微有些凌亂。四輻式的方向盤造型也難以提升駕駛員的駕駛興趣。馬兒跑得快還要不吃草作為全新一代輕客的代表之作,光有光鮮的外表、時尚的造型可不夠,選擇這類車型的消費者們更為看重的必然是它們的內在能力。

拼家底誰更厚?

全順:全順在輕客領域摸爬滾打也有將近五十年歷史了。它的原型車可以追溯到1953年福特生產的一款輕型商用車FK1000,它於1961被稱作Ford Taunus Transit。1965年,福特汽車英國公司推出第一代福特Transit全順,迅速取得了輕型貨車領域的主導地位,並在此後一直霸佔着歐洲輕型客貨車銷量冠軍,成為了輕型客貨車的代名詞。

依維柯:作為歐洲的輕型商用車之一,依維柯在歐洲市場佔據很大的市場份額。在1975年的時候依維柯公司正式成立,1978年第一代依維柯Daily誕生。並且一直發展到今日,依維柯一共經歷了六次換代。

誰才是真正的“顏值帝”

外觀設計各花入各眼,但就目前的眼光來看,新全順外觀設計相比起老款可謂是翻天覆地,時尚動感的外型設計,微微收緊的車頭、熏黑的大燈以及一條筆直斜向上一直延伸到車尾的線條設計,彷彿讓新全順一躍跳出了輕客這個領域。

而依維柯則是傳統的造型設計,菱形的前大燈以及方方正正的車頭設計讓它很難與時尚設計扯上關係,保持了輕客一貫的傳統印象,但沒能給人眼前一亮的感覺。

內飾誰更前衛

新全順的內飾設計採用了福特最新家族的設計語言,非對稱式的中控設計,外加黑色內飾加銀色鍍鉻配色,整體顯得更有檔次感,中控面板和門把手對於細節的處理也非常細緻,非常符合新全順的車型定位。

而依維柯的中控 則採用了深灰色的內飾配色,整體看起來略微有些沉悶。並且空調的出風口以及手套箱的設計相對過於緊湊,讓人感覺整个中控台略微有些凌亂。四輻式的方向盤造型也難以提升駕駛員的駕駛興趣。

馬兒跑得快還要不吃草

作為全新一代輕客的代表之作,光有光鮮的外表、時尚的造型可不夠,選擇這類車型的消費者們更為看重的必然是它們的內在能力。就這方面來看,全順的表現還是極為優秀的。從動力上看新全順所搭載的2.0T柴油渦輪增壓發動機雖在排量上比起依維柯的2.5T渦輪發動機稍顯劣勢,但由於全順採用了新的渦輪技術使得在排量吃虧的情況下,依然在能在功率上追上對手,並且在扭矩上還略微有優勢。

江鈴福特-全順

南京依維柯-power Daily

【聽宣判pK結果】:兩位老對手的定位雖然相近,但是結合兩輛車的表現,新全順更加出色,在各個項目的表現上都要更勝一籌。而依維柯則保留了純粹的商用車氣息,缺乏了一點新時代的便利性以及通用性。本站聲明:網站內容來源於http://www.auto6s.com/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

※為什麼 USB CONNECTOR 是電子產業重要的元件?

網頁設計一頭霧水該從何著手呢? 台北網頁設計公司幫您輕鬆架站!

※台北網頁設計公司全省服務真心推薦

※想知道最厲害的網頁設計公司"嚨底家"!

※推薦評價好的iphone維修中心

當年考車沒掛科?看完包你再也不敢裝老司機了…

學員在上課日本駕校的模擬駕駛訓練你以為學了這麼久,總算能拿證了。呵呵,天真。上面說的都只是駕校的必修課程,上完前面說的那些課之後,你會拿到一張類似准考證的東西。你需要做的是,拿着這張證,去參加正式的考試,萬一掛科了,就要回去駕校重。

每天當打開電腦,準備一覽天下,指點江山的時候,經常都會看到各類交通事故的彈窗新聞。點進去之後往評論區一看,這幾種回答絕對跑不掉:

“國產車鐵皮薄,就是不耐撞!”

“肯定是女司機引發的吧,馬路殺手啊……”

“戳我,海量資源,看妹妹自拍羞羞視頻妹妹&¥#…#%¥……”

其實不管是男是女,是國產車還是進口車,大多數情況下,發生交通事故的原因都是駕駛操作本身出現了問題。花了那麼多錢和時間,被教練“親切問候”了那麼多次,到頭來拿了駕照卻還是不會開車?難道是國內的駕考規則還不夠嚴?

要弄清楚這個問題,那就得深入探究一下,各國的駕考規則到底有什麼不同。所以今天就讓大家看一下,世界各國的人們到底是怎麼考駕照的。

最全面

德 國

德國人一向以嚴謹著稱,考駕照也不例外。在他們看來,開車不僅僅是一個人的事情,還關乎他人的生命,所以安全是絕對是被放在第一位的。

在德國,考駕照之前要先學8個小時的急救知識,止血、心肺復蘇等全部都要練得滾瓜爛熟。然後才能開始上車練,每次最少練1個半小時,一共練12次,其中包括4次高速公路練習和3次夜間道路練習。

在正式考試的時候沒有固定線路,要聽考官指揮怎麼走,基本上從繁忙道路到高速公路等各種路況都得走一遍。考核標準也比較人性化,比如考試過程中遇到突發障礙物,不管是繞行,剎車,還是停車後下車查看,這都是允許的,因為安全最重要。不會像國內的电子駕考,半路突然跑出個熊孩子,你一腳急剎車,反而算你掛科了。

值得一提的是,除了安全只是和駕駛技術,德國駕考還會把汽車知識也一起考了。考官會打開發動機蓋,問你這個零件是幹嘛的,那個零件壞了怎麼辦。注重安全之餘,也可見德國人對汽車真的是愛到骨子里。

缺點是學車價格比較貴,均價在1500歐左右,摺合人民幣10898元。

最麻煩

日 本

在日本學車也不是一件容易事,首先學費就很貴,一般費用在15000到20000人民幣之間。

重點是在日本學車,上課的壓力不比高考黨低。先要學交通安全知識10個小時,然後學駕駛理論15個小時,再然後是上車實操練習19個小時,最後還要16個小時的專業進修。

學員在上課

日本駕校的模擬駕駛訓練

你以為學了這麼久,總算能拿證了?呵呵,天真!上面說的都只是駕校的必修課程,上完前面說的那些課之後,你會拿到一張類似准考證的東西。你需要做的是,拿着這張證,去參加正式的考試,萬一掛科了,就要回去駕校重!新!學!

所以為了照顧那些需要快速拿證的學員,一些駕校推出了包含住宿在內駕考套餐,吃喝拉撒都在駕校里,最快兩個星期就能拿證。

最嚴格

芬 蘭

芬蘭出名的除了芬蘭浴和諾基亞之外,芬蘭人會開車也是另外一塊大招牌。芬蘭素來盛產冠軍車手,像哈基寧,萊科寧這兩位F1冠軍,都是芬蘭人。

哈基寧(左)和萊科寧(右)

用一句話概括芬蘭人的車技就是:沒人不會漂移。因為芬蘭地處北歐,常年積雪,車子行駛的時候附着力很差,所以對駕駛者的技術要求很高,偶爾需要用上漂移來過彎真的一點都沒有誇張的成分。

因此芬蘭的駕考標準相當嚴格,而且難度奇高。比如有一項考試就是讓學員在濕滑的地面上快速行駛,然後急剎車,看學員能不能在保持車身穩定的同時把車子停下來,稍有偏差就是掛科。由於芬蘭森林覆蓋率很高,路上隔三差五就有動物跳出來,所以考試里還有一項是用電腦模擬野生動物突然出現,用來測試學員的緊急反應能力。

有趣的是,芬蘭的交通罰款是按照駕駛者的收入來決定罰款高低的,跟收稅一樣。同樣的違規現象,越有錢的罰款越高。曾經有一次就是諾基亞的副總裁在限速50km/h的路上開到了75km/h,結果被罰了11萬6千歐元,摺合人民幣約84萬……

最簡單

韓 國

韓國駕考容易通過相信不少國內的駕考學員都知道,韓國的駕考是不會硬性要求學員去駕校學習的。先是進行筆試,內容非常簡單,60分就可以過,而且支持中文作答。

實操考試方面,只要你覺得你會開車,就可以去考了。考試內容也十分簡單,基本就是停停車,開開燈,然後在固定線路跑一遍就行了。如果你是有一點駕駛基礎的,提前在考試路段練幾遍基本都能過。因為可以選擇不上駕校,所以費用相對來說非常低,光是考駕照的花費來說的話,一千來塊人民幣就能搞定了。

因此之前不少國人由於擔心國內駕照考不過,或者嫌等考試的時間太長,都會報個十天團去韓國專門考駕照。可是這條門路現在已經基本被封起來了,因為從今年4月1日起,公安部就出台新規定,中國內地居民取得境外駕駛證時,在核發國家或地區連續居留不足三個月的,換領國內駕駛證時,需要參加全部考試科目。

總結

考駕照的目的就是為了讓自己成為一名合格的駕駛員,無論是對車內乘客,對路人,還是對自己,都是最起碼的責任。每個國家的國情和路況都有所不同,所以不能一概而論哪國的駕考標準更好。根據我國道路情況,認為現有的駕考規則還是比較能考驗出學員的駕駛水平的。建議大家都按照規矩來好好學車,別老想着走後門,畢竟考試掛總好過路上“掛”。本站聲明:網站內容來源於http://www.auto6s.com/,如有侵權,請聯繫我們,我們將及時處理

【其他文章推薦】

USB CONNECTOR掌控什麼技術要點? 帶您認識其相關發展及效能

台北網頁設計公司這麼多該如何選擇?

※智慧手機時代的來臨,RWD網頁設計為架站首選

※評比南投搬家公司費用收費行情懶人包大公開

※回頭車貨運收費標準