Python連接MySql數據庫

連接數據庫前，請先確認以下事項：

1.在你的機子上已經安裝了 Python MySQLdb 模塊。
2.已經創建了數據庫 test
3.連接數據庫test使用的用戶名為 root，密碼為 root,你可以可以自己設定或者直接使用root用戶名及其密碼。

import pymysql
    
    # 打開數據庫連接（ip/數據庫用戶名/登錄密碼/數據庫名）
    db = pymysql.connect("localhost", "root", "root", "test")
    # 使用 cursor() 方法創建一個游標對象 cursor
    cursor = db.cursor()
    
    # 使用 execute()  方法執行 SQL 查詢
    cursor.execute("SELECT VERSION()")
    # 使用 fetchone() 方法獲取單條數據.
    data = cursor.fetchone()
    print("Database version : %s " % data)
    
    # 關閉數據庫連接
    db.close()

Python操作MySql數據庫實現增刪改查

① 數據庫插入

import pymysql
    
    # 打開數據庫連接（ip/數據庫用戶名/登錄密碼/數據庫名）
    db = pymysql.connect("localhost", "root", "root", "test")
    # 使用 cursor() 方法創建一個游標對象 cursor
    cursor = db.cursor()
    
    # SQL 插入語句
    sql = """INSERT INTO user(name)
             VALUES ('Mac')"""
    try:
       # 執行sql語句
       cursor.execute(sql)
       # 提交到數據庫執行
       db.commit()
    except:
       # 如果發生錯誤則回滾
       db.rollback()
    
    # 關閉數據庫連接
    db.close()

②數據庫查詢

import pymysql
    
    # 打開數據庫連接（ip/數據庫用戶名/登錄密碼/數據庫名）
    db = pymysql.connect("localhost", "root", "root", "test")
    # 使用 cursor() 方法創建一個游標對象 cursor
    cursor = db.cursor()
    
    # SQL 查詢語句
    sql = "SELECT * FROM user"
    
    try:
        # 執行SQL語句
        cursor.execute(sql)
        # 獲取所有記錄列表
        results = cursor.fetchall()
        for row in results:
            id = row[0]
            name = row[1]
            # 打印結果
            print("id=%s,name=%s" % \
                  (id, name))
    except:
        print("Error: unable to fecth data")
    
    # 關閉數據庫連接
    db.close()

③數據庫更新

import pymysql
    
    # 打開數據庫連接（ip/數據庫用戶名/登錄密碼/數據庫名）
    db = pymysql.connect("localhost", "root", "root", "test")
    # 使用 cursor() 方法創建一個游標對象 cursor
    cursor = db.cursor()
    
    # SQL 更新語句
    sql = "UPDATE user SET name = 'Bob' WHERE id = 1"
    try:
        # 執行SQL語句
        cursor.execute(sql)
        # 提交到數據庫執行
        db.commit()
    except:
        # 發生錯誤時回滾
        db.rollback()
       
    # 關閉數據庫連接
    db.close()

④數據庫刪除

 import pymysql
    
    # 打開數據庫連接（ip/數據庫用戶名/登錄密碼/數據庫名）
    db = pymysql.connect("localhost", "root", "root", "test")
    # 使用 cursor() 方法創建一個游標對象 cursor
    cursor = db.cursor()
    
    # SQL 刪除語句
    sql = "DELETE FROM user WHERE id  = 1"
    try:
        # 執行SQL語句
        cursor.execute(sql)
        # 提交修改
        db.commit()
    except:
        # 發生錯誤時回滾
        db.rollback()
    
    # 關閉數據庫連接
    db.close()