標准國民經濟行業分類與代碼GB/T 4754-2011存入mysql數據庫

國標：

代碼：

import pandas as pd
import pymysql
"""
------------------------------------------------------------------------------------
"""
def get_conn():
    """
    :return: 連接，游標
    """
    # 創建連接
    conn = pymysql.connect(host="127.0.0.1",
                    user="root",
                    password="000429",
                    db="data_cleaning",
                    charset="utf8")
    # 創建游標
    cursor = conn.cursor()  # 執行完畢返回的結果集默認以元組顯示
    return conn, cursor

def close_conn(conn, cursor):
    if cursor:
        cursor.close()
    if conn:
        conn.close()
"""
-----------------------------------------------------------
"""
"""
------------------------------------------------------------------------------------
"""
def query(sql,*args):
    """
    通用封裝查詢
    :param sql:
    :param args:
    :return:返回查詢結果 （（），（））
    """
    conn , cursor= get_conn()
    print(sql)
    cursor.execute(sql)
    res = cursor.fetchall()
    close_conn(conn , cursor)
    return res
"""
------------------------------------------------------------------------------------
"""

def into_mysql(filename):
    category_code = ""      #門類編碼
    category_name = ""      #門類名稱

    conn,cursor=get_conn()  #連接mysql
    if(conn!=None):
        print("數據庫連接成功！")
    tempres = []            #暫存列表
    df=pd.read_excel(filename)      #讀取標准表
    # print(len(df.index))
    for i in range(len(df.index.values)):   #第一層遍歷標准表 找到門類的編碼和名稱 找到小類的編碼
        # print(df.loc[i][1])
        code=str(df.loc[i][0])           #所有的編碼
        name=str(df.loc[i][1])           #所有的名稱
        if len(code)==1:
            category_code=code     #門類編碼
            category_name=name     #門類名稱
        #分割編碼
        if len(code)==4:
            small_class=name        #小類名稱
            new_code_2=code[:2]     #分割出兩位編碼    之后確定大類名稱
            new_code_3=code[:3]     #分割出三位編碼    之后確定中類名稱
            print(category_code)    #最終的字符串需要門類的編碼ABCD和門類的名稱
            print(new_code_2)
            print(new_code_3)
            for j in range(len(df.index.values)):   #第二次遍歷 尋找不同的位數的編碼對應不同的名稱
                if new_code_2==df.loc[j][0]:
                    big_class=df.loc[j][1]    #大類名稱
                if new_code_3==df.loc[j][0]:
                    mid_class=df.loc[j][1]    #中類名稱
            tempres.append(category_code+code)              #列表暫存A0511 編碼
            tempres.append(category_name+"·"+big_class+"·"+mid_class+"·"+small_class)   #列表暫存完整的名稱
            print(tempres)
            SQL = "insert into std_code (code,name) values('"+tempres[0]+"','"+tempres[1]+"');"     #sql插入語句
            try:
                cursor.execute(SQL)             #執行sql語句
                conn.commit()                   #提交事務
                print("第"+str(i+1)+"條數據插入成功:\n",category_code+code,name)        #插入成功輸出
                print("--------------------------------------------------")
            except:
                print("插入失敗:\n",category_code+code,name)
            tempres=[]          #清空列表
    close_conn(conn,cursor)     #關閉數據庫連接
    return None
if __name__ == '__main__':
    filename="GBT4754-2011.xlsx"
    into_mysql(filename)

運行代碼輸出的內容截圖：

 

 

最終存入mysql數據庫截圖：