python pymysql庫的常用操作
批量插入
import pymysql def insert_to_mysql(to_db_list): mysql_db = pymysql.connect(host='HOST_IP', port=3306, user='username', password='password',database='db', charset='utf8') cursor = mysql_db.cursor() sql = 'INSERT INTO `your_db`.`your_table`(`colum1`, `colum2`, `colum3`) VALUES (%s,%s,%s)' try: # cursor.execute() cursor.executemany(sql, to_db_list) # 批量插入 effect_rows = cursor.rowcount mysql_db.commit() cursor.close() print(’數(shù)據(jù)庫添加成功,插入 {}條數(shù)據(jù)’.format(effect_rows)) return effect_rows except Exception as e: mysql_db.rollback() print(’數(shù)據(jù)庫執(zhí)行失敗’) print(e) return 0 my_list = []my_list.append((’v1’, ’v2’, ’v3’)) cnt = insert_to_mysql(my_list)
查詢
def get_id_name(): cursor = mysql_db.cursor() sql = 'select id, name from `your_db`.`table`' cursor.execute(sql) res = cursor.fetchall() # print(res) return res my_list = get_id_name() for index in range(len(my_list)): print(my_list[index][0]) # id print(my_list[index][1]) # name
更新
def update_by_id(update_list): '''根據(jù)ID更新col1, col2, col3 list 依次為 col1, col2, col3, id :param update_list: :return: ''' cursor = mysql_db.cursor() sql = 'UPDATE `your_db`.`table` SET col1=(%s),col2=(%s),col3=(%s) WHERE id=(%s)' try: # cursor.execute() cursor.executemany(sql, update_list) # 批量插入 mysql_db.commit() cursor.close() print(’數(shù)據(jù)庫更新成功’) except Exception as e: mysql_db.rollback() print(’數(shù)據(jù)庫更新失敗’) print(e) my_list = []my_list.append((’v1’, ’v2’, ’v3’, ’id’))update_by_id(my_list)
以上就是python pymysql庫的常用操作的詳細(xì)內(nèi)容,更多關(guān)于python pymysql庫的資料請(qǐng)關(guān)注好吧啦網(wǎng)其它相關(guān)文章!
相關(guān)文章:
1. IntelliJ IDEA設(shè)置自動(dòng)提示功能快捷鍵的方法2. idea重置默認(rèn)配置的方法步驟3. idea 打包的jar運(yùn)行報(bào) "XXX中沒有主清單屬性"4. Docker 部署 Prometheus的安裝詳細(xì)教程5. 通過Django Admin+HttpRunner1.5.6實(shí)現(xiàn)簡(jiǎn)易接口測(cè)試平臺(tái)6. IntelliJ IDEA安裝插件的方法步驟7. php過濾器使用詳解8. idea打開多個(gè)窗口的操作方法9. idea設(shè)置代碼格式化的方法步驟10. IntelliJ IDEA調(diào)整字體大小的方法

網(wǎng)公網(wǎng)安備