使用mysql.connector 向mysql表寫入數(shù)據(jù)

mysql.connector 是mysql官方提供的驅(qū)動器，可使用pip進行安裝

pip install mysql-connector

創(chuàng)建一張mysql表

create table city(
    id int NOT NULL AUTO_INCREMENT,
    `name` varchar(50) NOT NULL,
    PRIMARY KEY (`id`)
)ENGINE=InnoDB DEFAULT CHARSET=utf8;

接下來，向這張表里寫入數(shù)據(jù)

import mysql.connector

mydb = mysql.connector.connect(
    host="your ip",  # 數(shù)據(jù)庫主機地址
    user="username",  # 數(shù)據(jù)庫用戶名
    passwd="password",  # 數(shù)據(jù)庫密碼
    port=6606,
    database='flink_db'
)

sqls = [
    "insert into city(name)values('北京')",
    "insert into city(name)values('上海')",
    "insert into city(name)values('廣州')",
    "insert into city(name)values('深圳')",
]

mycursor = mydb.cursor()

for sql in sqls:
    mycursor.execute(sql)

mydb.commit()

insert 語句會向表里新增數(shù)據(jù)，數(shù)據(jù)庫有變動，必須執(zhí)行commit，否則不會生效