#--------------------------------------------------------------------
#範例13-7-2：讀取mySQL資料庫ch09, 讀取books全部資料
#-------------------------------------------------


#（1）步驟1：建議：mySQL範例要在anaconda裡面測試（不要再cola測試）
#要先安裝：python 3.x版本的安裝mysql的指令：pip install pymysql

#（2）步驟2：安裝mySQL
#安裝： wamp或xamp
#帳號為root，密碼不設定

#（3）步驟3：匯入chp9資料庫

#（4）步驟4：連線資料庫指令
#import pymysql
#conn = pymysql.connect(host="localhost",user="root", password="", db="ch09")

#（5）步驟5：查詢資料表，轉成df指令
#import pandas as pd
#df = pd.read_sql_query("select * from books", conn)


#------------------------------
#練習1：讀取mySQL資料庫
#------------------------------

#連線資料庫指令
import pymysql
conn = pymysql.connect(host="localhost",user="root", password="", db="ch09")

#查詢資料表，轉成df指令
import pandas as pd
df = pd.read_sql_query("select * from books", conn)

print()
print("1-1.顯示全部資料=\n", df)

print()
print("1-2.價格最高=", df['價格'].max())

print()
a1 = df['價格'] == df['價格'].max()
print("1-3.價格最高書籍資料=\n", df[a1])

print()
print("1-4.價格最高的前5本書=\n", df.sort_values(by='價格', ascending=False).head())


print()
a1 = df['負責員工編號']==2
print("1-5.員工編號2號負責的書籍資料=\n", df[a1])


print()
df['次數'] = 1
print("1-6.新增欄位『次數』，預設為1 = \n", df.head())

print()
import numpy as np
print("1-7.員工編號2號負責的書籍數量統計資料=\n", df.groupby(['負責員工編號']).size())

print()
print("1-8.員工編號2號負責的書籍數量統計資料=\n", df.groupby(['負責員工編號']).agg({'次數':np.sum}))

#關閉連線
conn.close()


#--------------------------------------------------------------------