Python3.7和數據庫MySQL 8.0.12 數據庫SQLite3鏈接(三)

SQLite3

# SQLite3 嵌入式 數據庫  python內置SQLite3
# 導入驅動
import sqlite3

# 建立自增主鍵的表
msql = "create table user (id integer primary key ,name varchar (20),password varchar (20))"
# 新增數據
msql2 = "insert into user (name,password) values ('Tom','xxxxx')"
# 更新數據
msql3 = "update user set name ='LiLei' where id = 1"
# 查詢數據
msql4 = "select id,name,password from user "

msql5 = "delete  from user where name = \"Tom\""

import sys


# 初始化數據庫
def InIt_Database():
    print("==========初始化數據庫")
    # 鏈接數據庫 若不存在 則自動建立
    mConnection = sqlite3.connect("testsqlite3.db")
    mCursor = mConnection.cursor()
    try:
        mCursor.execute(msql)
    except:
        # sys.exc_info()會返回一個3值原表(type,value,traceback)
        print("數據庫已經存在 不可重複建立 異常信息  ERROR=", sys.exc_info()[1])
    finally:
        mConnection.commit()
        mCursor.close()
        mConnection.close()
        print("==========初始化數據庫結束")

def Insert_test(msql):
    print("==========新增數據")
    # 鏈接數據庫 若不存在 則自動建立
    mConnection = sqlite3.connect("testsqlite3.db")
    mCursor = mConnection.cursor()
    mCursor.execute(msql)
    mConnection.commit()
    print("新增一條數據  返回行數:", mCursor.rowcount)

    mCursor.execute(msql4)
    print("==========查詢數據庫")
    for row in mCursor:
        print("ID=%s,Name=%s"%(row[0],row[1]))
    mConnection.commit()

    mCursor.close()
    mConnection.close()

def Update_test(msql):
    # 鏈接數據庫 若不存在 則自動建立
    mConnection = sqlite3.connect("testsqlite3.db")
    mCursor = mConnection.cursor()
    mCursor.execute(msql)
    mConnection.commit()

    mCursor.execute(msql4)
    for row in mCursor:
        print("ID=%s,Name=%s"%(row[0],row[1]))
    mConnection.commit()

    mCursor.close()
    mConnection.close()

def Delete_test(msql):
    # 鏈接數據庫 若不存在 則自動建立
    mConnection = sqlite3.connect("testsqlite3.db")
    mCursor = mConnection.cursor()
    mCursor.execute(msql)
    mConnection.commit()

    mCursor.execute(msql4)
    for row in mCursor:
        print("ID=%s,Name=%s"%(row[0],row[1]))
    mConnection.commit()

    mCursor.close()
    mConnection.close()

InIt_Database()
Insert_test(msql2)
Update_test(msql3)
Delete_test(msql5)