python 入门之数据库操作

作者：技能实验室

2022-10-19
河南
本文字数：1161 字
阅读完需：约 1 分钟

1、目前主流的数据库有两种，

一个是关系型数据库，如 MySql
一个是非关系型数据库如 mongodb

对与 mysql 和 mongodb 数据库，python 中分别有对接的连接操作库

2、python 连接 mysql:在 python 中，连接 mysql 用到的库是

pymysql

安装方法直接使用命令：

pip install pymsql

引入方式：

import pymysql

连接数据库：

db = pymysql.connect(host='127.0.0.1',                     user='root',                     password='123456',                     database='bookmanager')

复制代码

获取游标：

cur = db.cursor()

关闭数据库：

db.close()

使用 python 执行增删改查的操作的完整代码：

#!/usr/bin/python3 import pymysql db = pymysql.connect(host='127.0.0.1',                     user='root',                     password='123456',                     database='bookmanager')#print(db)cur = db.cursor()#print(cur)
# SQL 插入语句sql = """INSERT INTO BOOK(NAME,         AUTHOR, PUBLISH, HAVE, HOT)         VALUES ('001', 'test', '002', 100, 200)"""# 查询sql = "SELECT * FROM BOOK WHERE hot > 1000"
#修改sql = "UPDATE BOOK SET name = 'ZS1000' WHERE hot > 1000"
#删除sql = "delete FROM BOOK where  hot > 1000"
sql = """CREATE TABLE TEST (         FIRST_NAME  CHAR(20) NOT NULL,         LAST_NAME  CHAR(20),         AGE INT,           SEX CHAR(1),         INCOME FLOAT )"""#删除表sql = "DROP TABLE IF EXISTS TEST"


try:    cur.execute(sql)    db.commit()except:    print('have exception')    db.rollback()
db.close()

复制代码

3、python 连接 mongodb 的库是：

pymongo

安装以及引人：

pip install pymongoimport pymongo

建立数据库连接：

mongo_client = pymongo.MongoClient("mongodb://192.168.1.200:30000")

指定数据库：

mongo_db = mongo_client["test"]

操作数据库完整代码如下：

#!/usr/bin/python3 import pymongo
mongo_client =  pymongo.MongoClient("mongodb://192.168.1.200:30000")
print(mongo_client)
mongo_db = mongo_client["test"]
print(mongo_db)
#获取集合collist = mongo_db.list_collection_names()
#print(collist)
coll = mongo_db['new_coll']#print(coll)#coll.insert_one({'name':'new_coll'})#获取集合#collist = mongo_db.list_collection_names()#print(collist)
coll = mongo_db["new_coll"]
for x in coll.find():    print(x)
#query_my = {"name":"new_coll"}#update_q = {"$set":{"name":"new_coll_1"}}
#coll.update_one(query_my,update_q)#print(coll.find()[0])print('*'*25)query_my = {"name":"new_coll"}coll.delete_many(query_my)
for x in coll.find():    print(x)