今天小编给大家分享一下Python之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工具查看:
# 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工具查看:
# 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数据库怎么创建”这篇文章的所有内容,感谢各位的阅读!相信大家阅读完这篇文章都有很大的收获,小编每天都会为大家更新不同的知识,如果还想学习更多的知识,请关注亿速云行业资讯频道。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。