python_操作linux上的mysql

在編寫初期，遇見一個問題，發現怎么連接不上mysql，一直報錯1045；

最后發現，只要下面的，連接寫正確，不會出現這個問題， 只要你保證你的user、pwd是正確的，

 

import pymysql
db_config = {
        'user': 'root',
        'password': 'qwe123',
        'db': 'test',
        'charset':'utf8'
    }
    # 連接mysql數據庫
    con = pymysql.connect(**db_config)
    # 創建游標 ， 利用游標來執行sql語句
    cur = con.cursor()

基本連接是沒有問題的。

那我在重復下基本操作命令：

1、建立連接：pymysql.connect(**dbconfig)
       連接是不能操作數據庫的,需要用連接生成游標來操作
2、創建游標： connection.cursor()
3、執行SQL語句：cursor.execute(sql)
4、獲取結果：cur.fetchall()
5、事務的回滾： rollback()
6、事務的提交： commit()

 

這時，咱們在xshell_mysql 新建一些數據

新建表數據：

CREATE TABLE data_test(
                        id INT unique,
                        name VARCHAR(50), age INT, sex enum('男','女') );

 表內插入數據:

insert into data_test(id, name, age, sex) VALUES(1, '李牧', 18, '男'),(2, '栗子', 20, '女'),(3, '測試', 26, '男'),(4, '尕娃', 30, '女');

那么在xshell中查詢結果如下：

 

 那么我們在pycharm 怎么連接並查詢數據呢？

import pymysql

def tes_mysql():
    db_config = {
        'user': 'root',
        'password': 'qwe123',
        'db': 'test',
        'charset':'utf8'
    }
    # 連接mysql數據庫
    con = pymysql.connect(**db_config)
    # 創建游標 ， 利用游標來執行sql語句
    cur = con.cursor()

    try:
        # 執行sql語句，不會返回結果，返回其影響的行數
        executes = cur.execute("select * from data_test")
        # 獲取結果
        values = cur.fetchall()
        for value in values:
            print(value)

        # 提交到數據庫，真正把數據插入或者更新到數據
        con.commit()
    except Exception as e:
        print(e)
        # 發生了異常，回滾
        con.rollback()

    finally:
        # 在最后使用完關閉游標和連接
        # 關閉游標
        cur.close()
        # 關閉連接
        con.close()

 

再進行個參數化把，

定義 test_base.py

import pymysql

def tes_mysql(sql):
    db_config = {
        'user': 'root',
        'password': 'qwe123',
        'db': 'test',
        'charset':'utf8'
    }
    # 連接mysql數據庫
    con = pymysql.connect(**db_config)
    # 創建游標 ， 利用游標來執行sql語句
    cur = con.cursor()

    try:
        # 執行sql語句，不會返回結果，返回其影響的行數
        executes = cur.execute(sql)
        # 獲取結果
        values = cur.fetchall()
        for value in values:
            print(value)

        # 提交到數據庫，真正把數據插入或者更新到數據
        con.commit()
    except Exception as e:
        print(e)
        # 發生了異常，回滾
        con.rollback()

    finally:
        # 在最后使用完關閉游標和連接
        # 關閉游標
        cur.close()
        # 關閉連接
        con.close()

run_select.py

from day.test_base import tes_mysql

sql = "select * from data_test"
# 實例化
a = tes_mysql(sql)

運行結果：

 

簡單記錄一下。

 

 

作者：含笑半步顛√

博客鏈接：https://www.cnblogs.com/lixy-88428977

聲明：本文為博主學習感悟總結，水平有限，如果不當，歡迎指正。如果您認為還不錯，歡迎轉載。轉載與引用請注明作者及出處。