摘要：
Passwd='password'#密码，charset='utf8'#字符编码）cur=连接。cursor（）#生成游标对象sql=“select*from`student`”#sql语句cur。execute（sql）#执行sql语句data=cur。fetchall（）#通过fetchall方法为iindidata[：
1、Python MySQL - mysql-connector 驱动
1、安装mysql驱动
python -m pip install mysql-connector
2、测试驱动
import mysql.connector3、代码实现
1、基本操作
import mysql.connector conn=mysql.connector.connect(host = '127.0.0.1' # 连接名称，默认127.0.0.1 ,user = 'root' # 用户名 ,passwd='password' # 密码 ,port= 3306 # 端口，默认为3306 ,db='test' # 数据库名称 ,charset='utf8' # 字符编码 ) cur = conn.cursor() # 生成游标对象 sql="select * from `student` " # SQL语句 cur.execute(sql) # 执行SQL语句 data = cur.fetchall() # 通过fetchall方法获得数据 for i in data[:2]: # 打印输出前2条数据 print (i) cur.close() # 关闭游标 conn.close() # 关闭连接
2、增删改查
import mysql.connector # 1、创建数据库连接 mydb = mysql.connector.connect( host="localhost", # 数据库主机地址 user="yourusername", # 数据库用户名 passwd="yourpassword" # 数据库密码 ) print(mydb) # 2、创建数据库 mycursor = mydb.cursor() mycursor.execute("CREATE DATABASE runoob_db") # 3、显示数据库 mycursor.execute("SHOW DATABASES") for x in mycursor: print(x) # 4、创建数据表 mycursor.execute("CREATE TABLE sites (name VARCHAR(255), url VARCHAR(255))") # 5、查看表 mycursor.execute("SHOW TABLES") for x in mycursor: print(x) # 6、主键设置 mycursor.execute("ALTER TABLE sites ADD COLUMN id INT AUTO_INCREMENT PRIMARY KEY") mycursor.execute("CREATE TABLE sites (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), url VARCHAR(255))") # 7、插入数据 sql = "INSERT INTO sites (name, url) VALUES (%s, %s)" val = ("RUNOOB", "https://www.runoob.com") mycursor.execute(sql, val) mydb.commit() # 数据表内容有更新，必须使用到该语句 print(mycursor.rowcount, "记录插入成功。") # 8、批量插入数据 sql = "INSERT INTO sites (name, url) VALUES (%s, %s)" val = [ ('Google', 'https://www.google.com'), ('Github', 'https://www.github.com'), ('Taobao', 'https://www.taobao.com'), ('stackoverflow', 'https://www.stackoverflow.com/') ] mycursor.executemany(sql, val) mydb.commit() # 数据表内容有更新，必须使用到该语句 print(mycursor.rowcount, "记录插入成功。") # 9、查询数据 mycursor.execute("SELECT * FROM sites") myresult = mycursor.fetchall() # fetchall() 获取所有记录 for x in myresult: print(x) # 10、查询一条数据 mycursor.execute("SELECT * FROM sites") myresult = mycursor.fetchone() print(myresult) # 11、where条件语句 sql = "SELECT * FROM sites WHERE url LIKE '%oo%'" mycursor.execute(sql) myresult = mycursor.fetchall() for x in myresult: print(x) # 12、排序 sql = "SELECT * FROM sites ORDER BY name DESC" mycursor.execute(sql) myresult = mycursor.fetchall() for x in myresult: print(x) # 13、limit语句 mycursor.execute("SELECT * FROM sites LIMIT 3") myresult = mycursor.fetchall() for x in myresult: print(x) # 14、删除记录 sql = "DELETE FROM sites WHERE name = 'stackoverflow'" mycursor.execute(sql) mydb.commit() print(mycursor.rowcount, " 条记录删除") # 15、更新表数据：为了防止数据库查询发生 SQL 注入的攻击，我们可以使用 %s 占位符来转义更新语句的条件： sql = "UPDATE sites SET name = 'ZH' WHERE name = %s" mycursor.execute(sql) mydb.commit() print(mycursor.rowcount, " 条记录被修改") # 16、删除表 sql = "DROP TABLE IF EXISTS sites" # 删除数据表 sites mycursor.execute(sql)
2、pymysql对MySql数据库实现增删改查
1、安装pymysql
pip install PyMySQL
2、查看安装版本
pip show PyMySQL
3、pymysql使用
1、基本操作
import pymysql #连接数据库 conn=pymysql.connect(host = '127.0.0.1' # 连接名称，默认127.0.0.1 ,user = 'root' # 用户名 ,passwd='password' # 密码 ,port= 3306 # 端口，默认为3306 ,db='test' # 数据库名称 ,charset='utf8' # 字符编码 ) cur = conn.cursor() # 生成游标对象 sql="select * from `student` " # SQL语句 cur.execute(sql) # 执行SQL语句 data = cur.fetchall() # 通过fetchall方法获得数据 for i in data[:2]: # 打印输出前2条数据 print (i) cur.close() # 关闭游标 conn.close() # 关闭连接
2、增删改查
1、增 import pymysql #连接数据库 conn=pymysql.connect(host = '127.0.0.1' # 连接名称，默认127.0.0.1 ,user = 'root' # 用户名 ,passwd='password' # 密码 ,port= 3306 # 端口，默认为3306 ,db='test' # 数据库名称 ,charset='utf8' # 字符编码 ) cur = conn.cursor() # 生成游标对象 #=============插入语句=============================== sql= "INSERT INTO student VALUES ('p','魏六','17')" #=================================================== try: cur.execute(sql1) # 执行插入的sql语句 conn.commit() # 提交到数据库执行 except: coon.rollback()# 如果发生错误则回滚 conn.close() # 关闭数据库连接 然后我们再运行查询语句 import mysql.connector conn=mysql.connector.connect(host = '127.0.0.1' # 连接名称，默认127.0.0.1 ,user = 'root' # 用户名 ,passwd='password' # 密码 ,port= 3306 # 端口，默认为3306 ,db='test' # 数据库名称 ,charset='utf8' # 字符编码 ) cur = conn.cursor() # 生成游标对象 sql="select * from `student` " # SQL语句 cur.execute(sql) # 执行SQL语句 data = cur.fetchall() # 通过fetchall方法获得数据 for i in data[:]: # 打印输出所有数据 print (i) cur.close() # 关闭游标 conn.close() # 关闭连接 执行结果就是 ('b', '钱二', '16') ('c', '张三', '17') ('d', '李四', '17') ('e', '王五', '16') ('a', '赵大', '16') ('p', '魏六', '17') 2、删 import pymysql #连接数据库 conn=pymysql.connect(host = '127.0.0.1' # 连接名称，默认127.0.0.1 ,user = 'root' # 用户名 ,passwd='password' # 密码 ,port= 3306 # 端口，默认为3306 ,db='test' # 数据库名称 ,charset='utf8' # 字符编码 ) cur = conn.cursor() # 生成游标对象 #=============删除语句=============================== sql = "DELETE FROM student WHERE `学号` = "a" #=================================================== try: cur.execute(sql) # 执行插入的sql语句 conn.commit() # 提交到数据库执行 except: coon.rollback()# 如果发生错误则回滚 conn.close() # 关闭数据库连接 3、改 import pymysql #连接数据库 conn=pymysql.connect(host = '127.0.0.1' # 连接名称，默认127.0.0.1 ,user = 'root' # 用户名 ,passwd='password' # 密码 ,port= 3306 # 端口，默认为3306 ,db='test' # 数据库名称 ,charset='utf8' # 字符编码 ) cur = conn.cursor() # 生成游标对象 #=============删除语句=============================== sql ="UPDATE student SET `学员姓名` = '欧阳' WHERE `学号` = 'b' " #=================================================== try: cur.execute(sql) # 执行插入的sql语句 conn.commit() # 提交到数据库执行 except: coon.rollback()# 如果发生错误则回滚 conn.close() # 关闭数据库连接 4、查 import pymysql #连接数据库 conn=pymysql.connect(host = '127.0.0.1' # 连接名称，默认127.0.0.1 ,user = 'root' # 用户名 ,passwd='password' # 密码 ,port= 3306 # 端口，默认为3306 ,db='test' # 数据库名称 ,charset='utf8' # 字符编码 ) cur = conn.cursor() # 生成游标对象 #=============删除语句=============================== sql="select * from `student` " # SQL语句 #==================================================== try: cur.execute(sql) # 执行插入的sql语句 data = cur.fetchall() for i in data[:]: print (i) conn.commit() # 提交到数据库执行 except: coon.rollback()# 如果发生错误则回滚 conn.close() # 关闭数据库连接
3、小型案列
import pymysql config = { 'host': '127.0.0.1', 'port': 3306, 'user': 'root', 'passwd': 'password', 'charset':'utf8', } conn = pymysql.connect(**config) cursor = conn.cursor() try: # 创建数据库 DB_NAME = 'test_3' cursor.execute('DROP DATABASE IF EXISTS %s' %DB_NAME) cursor.execute('CREATE DATABASE IF NOT EXISTS %s' %DB_NAME) conn.select_db(DB_NAME) #创建表 TABLE_NAME = 'bankData' cursor.execute('CREATE TABLE %s(id int primary key,money int(30))' %TABLE_NAME) # 批量插入纪录 values = [] for i in range(20): values.append((int(i),int(156*i))) cursor.executemany('INSERT INTO bankData values(%s,%s)',values) conn.commit() # 查询数据条目 count = cursor.execute('SELECT * FROM %s' %TABLE_NAME) print ('total records:{}'.format(cursor.rowcount)) # 获取表名信息 desc = cursor.description print ("%s %3s" % (desc[0][0], desc[1][0])) cursor.scroll(10,mode='absolute') results = cursor.fetchall() for result in results: print (result) except: import traceback traceback.print_exc() # 发生错误时会滚 conn.rollback() finally: # 关闭游标连接 cursor.close() # 关闭数据库连接 conn.close()
4、综合案列
from pymysql import * class Mysqlpython: def __init__(self, database='test', host='127.0.0.1', user="root", password='password', port=3306, charset="utf8"): self.host = host self.user = user self.password = password self.port = port self.database = database self.charset = charset # 数据库连接方法: def open(self): self.db = connect(host=self.host, user=self.user, password=self.password, port=self.port, database=self.database, charset=self.charset) # 游标对象 self.cur = self.db.cursor() # 数据库关闭方法: def close(self): self.cur.close() self.db.close() # 数据库执行操作方法: def Operation(self, sql): try: self.open() self.cur.execute(sql) self.db.commit() print("ok") except Exception as e: self.db.rollback() print("Failed", e) self.close() # 数据库查询所有操作方法: def Search(self, sql): try: self.open() self.cur.execute(sql) result = self.cur.fetchall() return result except Exception as e: print("Failed", e) self.close() def Insert():#如何从外面将数据录入到sql语句中 ID = int(input("请输入球员编号：")) people_name = input("请输入球员名字：") PAC = int(input("请输入速度评分：")) DRI = int(input("请输入盘带评分：")) SHO = int(input("请输入射门评分：")) DEF = int(input("请输入防守评分：")) PAS = int(input("请输入传球评分：")) PHY = int(input("请输入身体评分：")) score =(PAC+DRI+SHO+DEF+PAS+PHY)/6 sql_insert = "insert into FIFA(ID, people_name, PAC,DRI,SHO,DEF, PAS, PHY, score) values(%d,'%s',%d,%d,%d,%d,%d,%d,%d)"%(ID, people_name, PAC,DRI,SHO,DEF, PAS, PHY, score) print(people_name) return sql_insert def Project(): print("球员的能力评分有：") list=['速度','盘带','射门','防守','传球','身体','综合'] print(list) def Exit(): print("欢迎下次使用!!!") exit() def Search_choice(num): date = Mysqlpython() date.open() if num=="2": # 1.增加操作 sql_insert = Insert() date.Operation(sql_insert) print("添加成功！") Start() elif num=="1": # 2.查找数据,其中order by 是为了按什么顺序输出，asc 是升序输出，desc降序输出 input_date=input("请选择您想要以什么格式输出：默认升序排列1.球员编号，2.速度，3.盘带，4.射门， 5.防守， 6.传球， 7.身体 ， 8.综合 ") if input_date=="1": sql_search = "select * from FIFA order by ID asc" elif input_date=="2": sql_search = "select * from FIFA order by PAC asc" elif input_date=="3": sql_search = "select * from FIFA order by DRI asc" elif input_date=="4": sql_search = "select * from FIFA order by SHO asc" elif input_date=="5": sql_search = "select * from FIFA order by DEF asc" elif input_date=="6": sql_search = "select * from FIFA order by PAS asc" elif input_date=="7": sql_search = "select * from FIFA order by PHY asc" elif input_date=="8": sql_search = "select * from FIFA order by PHY score" else: print("请重新输入！") result = date.Search(sql_search) print(" 编号 姓名 速度 盘带 射门 防守 传球 身体 综合 ") for str in result: print(str) Start() elif num=="3": Project() Start() elif num=="4": del_num=input("请输入您要删除球员的编号：") sql_delete="delete from FIFA where id=%s"%del_num date.Operation(sql_delete) print("删除成功！") Start() elif num=="5": Exit() else: print("输入有误，请重新输入！") def Start(): print("********************************************************") print("* 欢迎来到FIFA球员信息系统 *") print("*1.查看球员信息 2.球员信息录入 *") print("*3.球员能力 4.删除球员信息 *") print("*5.退出系统 *") print("********************************************************") choice = input("请输入您的选择：") Search_choice(choice) if __name__=="__main__": Start()
5、银行转账系统
1、配置mysql信息
import pymysql config = { 'host': '127.0.0.1', 'port': 3306, 'user': 'root', 'passwd': 'password', 'charset':'utf8', } conn = pymysql.connect(**config) cursor = conn.cursor() try: # 创建数据库 DB_NAME = 'test_3' cursor.execute('DROP DATABASE IF EXISTS %s' %DB_NAME) cursor.execute('CREATE DATABASE IF NOT EXISTS %s' %DB_NAME) conn.select_db(DB_NAME) #创建表 TABLE_NAME = 'bankData' cursor.execute('CREATE TABLE %s(id int primary key,money int(30))' %TABLE_NAME) # 批量插入纪录 values = [] for i in range(20): values.append((int(i),int(156*i))) cursor.executemany('INSERT INTO bankData values(%s,%s)',values) conn.commit() # 查询数据条目 count = cursor.execute('SELECT * FROM %s' %TABLE_NAME) print ('total records:{}'.format(cursor.rowcount)) # 获取表名信息 desc = cursor.description print ("%s %3s" % (desc[0][0], desc[1][0])) cursor.scroll(10,mode='absolute') results = cursor.fetchall() for result in results: print (result) except: import traceback traceback.print_exc() # 发生错误时会滚 conn.rollback() finally: # 关闭游标连接 cursor.close() # 关闭数据库连接 conn.close() 2、构建系统 import pymysql class TransferMoney(object): # 构造方法 def __init__(self, conn): self.conn = conn self.cur = conn.cursor() def transfer(self, source_id, target_id, money): if not self.check_account_avaialbe(source_id): raise Exception("账户不存在") if not self.check_account_avaialbe(target_id): raise Exception("账户不存在") if self.has_enough_money(source_id, money): try: self.reduce_money(source_id, money) self.add_money(target_id, money) except Exception as e: print("转账失败:", e) self.conn.rollback() else: self.conn.commit() print("%s给%s转账%s金额成功" % (source_id, target_id, money)) def check_account_avaialbe(self, acc_id): """判断帐号是否存在， 传递的参数是银行卡号的id""" select_sqli = "select * from bankData where id=%d;" % (acc_id) print("execute sql:", select_sqli) res_count = self.cur.execute(select_sqli) if res_count == 1: return True else: # raise Exception("账户%s不存在" %(acc_id)) return False def has_enough_money(self, acc_id, money): """判断acc_id账户上金额> money""" # 查找acc_id存储金额? select_sqli = "select money from bankData where id=%d;" % (acc_id) print("execute sql:", select_sqli) self.cur.execute(select_sqli) # ((1, 500), ) # 获取查询到的金额钱数; acc_money = self.cur.fetchone()[0] # 判断 if acc_money >= money: return True else: return False def add_money(self, acc_id, money): update_sqli = "update bankData set money=money+%d where id=%d" % (money, acc_id) print("add money:", update_sqli) self.cur.execute(update_sqli) def reduce_money(self, acc_id, money): update_sqli = "update bankData set money=money-%d where id=%d" % (money, acc_id) print("reduce money:", update_sqli) self.cur.execute(update_sqli) # 析构方法 def __del__(self): self.cur.close() self.conn.close() if __name__ == '__main__': # 1. 连接数据库， conn = pymysql.connect(host = '127.0.0.1' # 连接名称，默认127.0.0.1 ,user = 'root' # 用户名 ,passwd='password' # 密码 ,port= 3306 # 端口，默认为3306 ,db='test_3' # 数据库名称 ,charset='utf8' ,autocommit=True, # 如果插入数据，自动提交给数据库 ) trans = TransferMoney(conn) trans.transfer(15, 12, 200)
3、python3连接oracle
Python一个官方网站PyPI，上面有丰富的模块。cx_Oracle就可以在PyPI中下载。打开PyPI的网址https://pypi.python.org/pypi，在里面搜索cx_Oracle，即可找到该模块，其下载地址为https://pypi.org/project/cx_Oracle/#files。
安装这个得先在cmd下输入：pip install wheel(如果报错则输入：pip.exe install wheel）。安装完毕，还是在cmd里，用dos命令找到cx_Oracle下载位置。下面放上dos进入路径的命令用法。
大概就是这样，然后继续输入安装cx-Oracle的命令，注意：这命令是用来装.whl文件的。
命令：pip install cx_Oracle-6.4.1-cp37-cp37m-win64.whl
import cx_Oracle #连接数据库，下面括号里内容根据自己实际情况填写 conn = cx_Oracle.connect('用户名/密码@IP:端口号/SERVICE_NAME') # 使用cursor()方法获取操作游标 cursor = conn.cursor() #使用fetchone()方法获取一条数据 #data=cursor.fetchone() #获取所有数据 all_data=cursor.fetchall() #获取部分数据，8条 #many_data=cursor.fetchmany(8) print (all_data) db.close() #使用fetchone()方法获取一条数据 #data=cursor.fetchone() #获取所有数据 all_data=cursor.fetchall() #获取部分数据，8条 #many_data=cursor.fetchmany(8) print (all_data) db.close()