18.python关于mysql的api

一.pymysql模块
1.pymysql是Python中操作MySQL的模块
2.执行sql语句
(1)连接数据库：

import pymysql

#连接mysql数据库创建conn对象（host连接的机器，user连接的用户，password连接的密=密码，db连接的数据库 ）
conn = pymysql.connect(host=‘192.168.1.232‘, port=3306, user=‘root‘, passwd=‘123456‘, db=‘xixi‘)

#创建游标,默认是元组,可以改为字典:conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

(2)创建表：

import pymysql

#连接mysql数据库创建conn对象（host连接的机器，user连接的用户，password连接的密=密码，db连接的数据库 ）
conn = pymysql.connect(host=‘192.168.1.232‘, port=3306, user=‘root‘, passwd=‘123456‘, db=‘xixi‘)

#创建游标,默认是元组,可以改为字典:conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

#生成sql创建xixi表的语句
sql = "CREATE TABLE xixi (id INT ,name VARCHAR (20))"
#通过游标执行SQL命令语句
cursor.execute(sql)

查看结果：
+-------+-------------+------+-----+---------+-------+
| Field | Type        | Null | Key | Default | Extra |
+-------+-------------+------+-----+---------+-------+
| id    | int(11)     | YES  |     | NULL    |       |
| name  | varchar(20) | YES  |     | NULL    |       |
+-------+-------------+------+-----+---------+-------+
(3)插入数据：

import pymysql

#连接mysql数据库创建conn对象（host连接的机器，user连接的用户，password连接的密=密码，db连接的数据库 ）
conn = pymysql.connect(host=‘192.168.1.232‘, port=3306, user=‘root‘, passwd=‘123456‘, db=‘xixi‘)

#创建游标,默认是元组,可以改为字典:conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

#插入四条数据
cursor.execute("INSERT INTO  xixi VALUES(1,‘dongdong‘),(2,‘nannan‘),(3,‘xixi‘),(4,‘beibei‘)")
#进行提交（在对数据库中的内容进行修改时，需要进行提交内容方可进行保存）
conn.commit()

查看结果：
+------+----------+
| id   | name     |
+------+----------+
|    1 | dongdong |
|    2 | nannan   |
|    3 | xixi     |
|    4 | beibei   |
+------+----------+
(4)查表数据
方式一：查询游标起始的第一条结果

import pymysql

#连接mysql数据库创建conn对象（host连接的机器，user连接的用户，password连接的密=密码，db连接的数据库 ）
conn = pymysql.connect(host=‘192.168.1.232‘, port=3306, user=‘root‘, passwd=‘123456‘, db=‘xixi‘)

#创建游标,默认是元组,可以改为字典:conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

#查数据
RET=cursor.execute("select * from xixi")
one=cursor.fetchone()
print(one)

查询结果：
{‘id‘: 1, ‘name‘: ‘dongdong‘}
方式二：查询游标起始的俩条数据

import pymysql

#连接mysql数据库创建conn对象（host连接的机器，user连接的用户，password连接的密=密码，db连接的数据库 ）
conn = pymysql.connect(host=‘192.168.1.232‘, port=3306, user=‘root‘, passwd=‘123456‘, db=‘xixi‘)

#创建游标,默认是元组,可以改为字典:conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

#查数据
many=cursor.fetchmany(2)
print(many)

查询结果：
[{‘id‘: 1, ‘name‘: ‘dongdong‘}, {‘id‘: 2, ‘name‘: ‘nannan‘}]
方式三：查询游标起始的所有数据

import pymysql

#连接mysql数据库创建conn对象（host连接的机器，user连接的用户，password连接的密=密码，db连接的数据库 ）
conn = pymysql.connect(host=‘192.168.1.232‘, port=3306, user=‘root‘, passwd=‘123456‘, db=‘xixi‘)

#创建游标,默认是元组,可以改为字典:conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

#查数据
all=cursor.fetchall()
print(all)

查询结果：
[{‘id‘: 1, ‘name‘: ‘dongdong‘}, {‘id‘: 2, ‘name‘: ‘nannan‘}, {‘id‘: 3, ‘name‘: ‘xixi‘}, {‘id‘: 4, ‘name‘: ‘beibei‘}]
(5)scroll移动当前的游标
方式一：相对当前位置向上下移动(负数是向上，正数是向下)

import pymysql

#连接mysql数据库创建conn对象（host连接的机器，user连接的用户，password连接的密=密码，db连接的数据库 ）
conn = pymysql.connect(host=‘192.168.1.232‘, port=3306, user=‘root‘, passwd=‘123456‘, db=‘xixi‘)

#创建游标,默认是元组,可以改为字典:conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

#查数据
RET=cursor.execute("select * from xixi")
one=cursor.fetchone()                       #第一次查询
print(one)

#scroll移动当前的游标
cursor.scroll(1,mode=‘relative‘)          #游标向下移动1位

one=cursor.fetchone()                       #第二次查询
print(one)

查询结果：
{‘id‘: 1, ‘name‘: ‘dongdong‘}
{‘id‘: 3, ‘name‘: ‘xixi‘}
方式二：把游标位置移动到相对的位置

import pymysql

#连接mysql数据库创建conn对象（host连接的机器，user连接的用户，password连接的密=密码，db连接的数据库 ）
conn = pymysql.connect(host=‘192.168.1.232‘, port=3306, user=‘root‘, passwd=‘123456‘, db=‘xixi‘)

#创建游标,默认是元组,可以改为字典:conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

#查数据
RET=cursor.execute("select * from xixi")
one=cursor.fetchone()                       #第一次查询
print(one)

cursor.scroll(3,mode=‘absolute‘)          #把游标位置移动到3的位置

one=cursor.fetchone()                       #第二次查询
print(one)

查询结果：
{‘id‘: 1, ‘name‘: ‘dongdong‘}
{‘id‘: 4, ‘name‘: ‘beibei‘}
二.python中调用数据库启动事务
当前account表
+------+--------+---------+
| id   | name   | balance |
+------+--------+---------+
|    1 | xixi   |   10000 |
|    2 | beibei |   10000 |
+------+--------+---------+
python代码：

import pymysql

#连接mysql数据库创建conn对象（host连接的机器，user连接的用户，password连接的密=密码，db连接的数据库 ）
conn = pymysql.connect(host=‘192.168.1.232‘, port=3306, user=‘root‘, passwd=‘123456‘, db=‘xixi‘)

#创建游标,默认是元组,可以改为字典:conn.cursor(cursor=pymysql.cursors.DictCursor)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

try:
    insertSQL0="INSERT INTO  account(id,name,balance) VALUES (3,‘yeye‘,4000)"    #给账户插入一条信息
    insertSQL1="UPDATE account set balance=balance-2000 WHERE name=‘xixi‘"        #给xixi减去2000
    insertSQL2="UPDATE account set balance=balance+2000 WHERE name=‘beibei‘"     #给beibei加2000

    cursor = conn.cursor()

    cursor.execute(insertSQL0)     #执行insertSQL0
    conn.commit()                  #提交insertSQL0的语句到数据库里

    cursor.execute(insertSQL1)     #执行insertSQL1
    raise Exception                #发生错误跳到except Exception as e
    cursor.execute(insertSQL2)
    cursor.close()
    conn.commit()                  

except Exception as e:            #如果捕捉到错误

    conn.rollback()                #执行回滚事务到上一次commit的地方代码继续往下走
    conn.commit()

cursor.close()
conn.close()

查询account表结果：
+------+--------+---------+
| id   | name   | balance |
+------+--------+---------+
|    1 | xixi   |   10000 |
|    2 | beibei |   10000 |
|    3 | yeye   |    4000 |
+------+--------+---------+

原文地址：https://www.cnblogs.com/xixi18/p/10115417.html

时间： 2024-10-16 09:43:24

18.python关于mysql的api的相关文章

python控制mysql的API手记

--------------------python控制mysql的API--------------------#import MySQLdb:引用对应的开发包#conn=MySQLdb.connect (host='localhost',user='root',passwd='root',db='test',port=3306):创建数据 库连接#cur=conn.cursor():创建游标 #cur.execute(self, query, args):执行单条sql语句,接收的参数为sq

第三篇 Python关于mysql的API--pymysql模块

python关于mysql的API--pymysql模块 pymysql是Python中操作MySQL的模块,其使用方法和py2的MySQLdb几乎相同. 模块安装 pip install pymysql 执行sql语句 在Python里写原生sql,就是把原生sql放到了一个接口里去执行 import pymysql # 1. 连接数据库后返回但是一个连接对象,有这个连接对象,就可以对数据库进行操作 conn = pymysql.connect( host = "127.0.0.1"

python操作MySQL

本篇对于Python操作MySQL主要使用两种方式: 原生模块 pymsql ORM框架 SQLAchemy pymsql pymsql是Python中操作MySQL的模块,其使用方法和MySQLdb几乎相同. 下载安装 ? 1 pip3 install pymysql 使用操作 1.执行SQL + ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 #!/usr/bin/env python # -*-

python基础教程学习笔记---(7)python操作mysql

1.基本介绍: python标准数据库接口为python DB-API,它为开发人员提供了数据库应用编程接口,可以支持mysql.Oracle.MSSQL.Sybase等多种数据库,不同的数据库需要下载不同的DB-API模块. DBI-API是一个规范,它定义了一系列必须的对象和数据库存取方式,以便为各种各样的底层数据库系统和多种多样的数据库接口程序提供一致的访问接口. python DB-API的使用流程是: ①引入API模块:②获取与数据库的连接:③执行SQL语句:④关闭数据库连接. 2.什

Python操作mysql之插入数据

之前有写过一篇python查询mysql数据的文章,今天写通过python插入数据到mysql数据库. 1.先建库,建表,建用户 mysql> create database top_ten; mysql> use top_ten mysql> create table log (id int PRIMARY KEY  AUTO_INCREMENT, ip char(20), url char(30), status int, total int) charset=utf8; mysql

python数据库(mysql)操作

一.软件环境 python环境默认安装了sqlite3,如果需要使用sqlite3我们直接可以在python代码模块的顶部使用import sqlite3来导入该模块.本篇文章我是记录了python操作mysql数据库,mysql数据库下载 由于我之前安装的是wampserver,默认安装了php.mysql和apache这3个环境,因此我没有在单独安装mysql数据库,只是下载了一个mysql管理工具Navicat for MySQL.在使用Navicat for MySQL连接本地mysql

mysql数据库----python操作mysql ------pymysql和SQLAchemy

本篇对于Python操作MySQL主要使用两种方式: 原生模块 pymsql ORM框架 SQLAchemy 一.pymysql pymsql是Python中操作MySQL的模块,其使用方法和MySQLdb几乎相同. 下载安装 pip3 install pymysql 使用操作 1.执行SQL 1 #!/usr/bin/env python 2 # -*- coding:utf-8 -*- 3 import pymysql 4 5 # 创建连接 6 conn = pymysql.connect(

Python 12 - Mysql & ORM

本节内容 1.数据库介绍 2.mysql数据库安装使用 3.mysql数据库基础 4.mysql命令 5.事务 6.索引 7.Python操作mysql 8.ORM sqlalchemy了解 数据库介绍 什么是数据库? (介于本人还是属于熟悉数据库的,这一块就基本复制粘贴了) 数据库(Database)是按照数据结构来组织.存储和管理数据的仓库, 每个数据库都有一个或多个不同的API用于创建,访问,管理,搜索和复制所保存的数据. 我们也可以将数据存储在文件中,但是在文件中读写数据速度相对较慢.

Python操作MySQL(1)

Python操作MySQL Python DB-API Python标准数据接口为Python DB-API,其提供了数据库应用编程接口. Python DB-API使用流程: 引用API模块 获取与数据库的连接 执行sql语句与存储过程 关闭数据库连接 安装pymysql pymysql是用于Python连接mysql数据库的接口,它实现了Python数据库API规范V2.0,基于 MySQL C API 上建立的. 连接数据库 连接数据库前,必须确保以下事项: 1. 已经安装了mysql服务