Python之MySQL數據庫怎么創建

今天小編給大家分享一下Python之MySQL數據庫怎么創建的相關知識點，內容詳細，邏輯清晰，相信大部分人都還太了解這方面的知識，所以分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后有所收獲，下面我們一起來了解一下吧。

一、創建MySQL數據表

# coding=utf-8
from pymysql import *
def connectDB():
    '''
    連接本地MySQL數據庫，指定連接的庫為test庫。
    :return:
    '''
    db = connect(host='localhost', user='root', password='123456', port=3306, db='test')
    return db
db = connectDB()
print(type(db))
def createTable(db):
    c = db.cursor()
    try:
        c.execute('''create table persons
                    (id int primary key not null,
                    name text not null,
                    age int not null,
                    address char(100),
                    salary real);''')
        db.commit()
        db.commit()
        return True
    except:
        db.rollback()
    return False
if createTable(db):
    print('create table success')
else:
    print('create table failed')

使用navicat工具查看： 

三、向MySQL表中插入數據

# coding=utf-8
from pymysql import *
def connectDB():
    '''
    連接本地MySQL數據庫，指定連接的庫為test庫。
    :return:
    '''
    db = connect(host='localhost', user='root', password='123456', port=3306, db='test')
    return db
db = connectDB()
print(type(db))
def insertRecords(db):
    cursor = db.cursor()
    try:
        cursor.execute("delete from persons")
        cursor.execute('''
        insert into persons(id,name,age,address,salary)
        values(1, 'GuHanZhe', 18, 'China', 9999)
        ''')
        cursor.execute('''
        insert into persons(id,name,age,address,salary)
        values(2, 'XiaoZhang', 55, 'China', 9)
        ''')
        db.commit()
        return True
    except Exception as e:
        print(e)
        db.rollback()
    return False
if insertRecords(db):
    print("成功插入記錄")
else:
    print("插入記錄失敗")

使用navicat工具查看：

三、查詢MySQL中的數據

# coding=utf-8
from pymysql import *
def connectDB():
    '''
    連接本地MySQL數據庫，指定連接的庫為test庫。
    :return:
    '''
    db = connect(host='localhost', user='root', password='123456', port=3306, db='test')
    return db
db = connectDB()


def selectRecords(db):
    cursor = db.cursor()
    sql = 'select name,age,salary from persons order by age desc'
    cursor.execute(sql)
    results = cursor.fetchall()
    print(results)
    print(type(results))    # 打印發現是元組類型

selectRecords(db)
db.close()

• 我們發現查詢數據輸出類型是元組類型，如果我們想要將字段名和查詢出的數據一一對應該怎么做呢？

• 這里就需要用到兩個很常用的函數dict()和zip()，如下：

# coding=utf-8
import json
from pymysql import *
def connectDB():
    '''
    連接本地MySQL數據庫，指定連接的庫為test庫。
    :return:
    '''
    db = connect(host='localhost', user='root', password='123456', port=3306, db='test')
    return db
db = connectDB()


def selectRecords(db):
    cursor = db.cursor()
    sql = 'select name,age,salary from persons order by age desc'
    cursor.execute(sql)
    results = cursor.fetchall()
    print(results)
    print(type(results))    # 打印發現是元組類型

    # 將字段名和查詢結果整合在一起
    fields = ['name', 'age', 'salary']
    records = []
    for row in results:
        records.append(dict(zip(fields, row)))
    return json.dumps(records)      # 輸出類型為JSON字符串
endresults = selectRecords(db)
print(endresults)
db.close()

以上就是“Python之MySQL數據庫怎么創建”這篇文章的所有內容，感謝各位的閱讀！相信大家閱讀完這篇文章都有很大的收獲，小編每天都會為大家更新不同的知識，如果還想學習更多的知識，請關注億速云行業資訊頻道。