ETL是一種數(shù)據(jù)處理方式,用于將來(lái)自不同源的數(shù)據(jù)抽取 (Extract)、轉(zhuǎn)換 (Transform) 和加載 (Load) 到一個(gè)目標(biāo)數(shù)據(jù)庫(kù)或數(shù)據(jù)倉(cāng)庫(kù)中。其中連接 MySQL 數(shù)據(jù)庫(kù)就是 ETL 中的一個(gè)重要步驟。
# Python 連接 MySQL import mysql.connector mydb = mysql.connector.connect( host="localhost", user="yourusername", password="yourpassword", database="mydatabase" ) print(mydb) # 對(duì) MySQL 數(shù)據(jù)庫(kù)進(jìn)行操作 mycursor = mydb.cursor() mycursor.execute("CREATE TABLE customers (name VARCHAR(255), address VARCHAR(255))") mycursor.execute("INSERT INTO customers (name, address) VALUES (%s, %s)", ("John", "Highway 21"))
以上代碼中,我們首先使用mysql.connector
模塊建立與 MySQL 數(shù)據(jù)庫(kù)的連接(需要提供主機(jī)名、用戶名、密碼和數(shù)據(jù)庫(kù)名稱等信息),然后使用cursor()
方法創(chuàng)建游標(biāo)對(duì)象,并使用游標(biāo)對(duì)象執(zhí)行 SQL 語(yǔ)句(例如創(chuàng)建新表、插入數(shù)據(jù)等操作)。
需要注意的是,連接 MySQL 數(shù)據(jù)庫(kù)時(shí),需要確保安裝了 MySQL 的 Python 驅(qū)動(dòng)程序(例如mysql-connector-python
)。