Pyhton 操作MySQL数据库

 

   MySQL数据库的接口程序下载地址:https://sourceforge.net/projects/mysql-python/

操作数据库的大致步骤如下:

1:首先先创建一个数据库的连接对象connection;

2:然后用连接对象创建游标对象;

3:用游标对象操作数据库(比如:增删查改);

4:最后提交事务或回滚事务。

连接对象connection有以下方法:

cursor()        -------------------------------     创建并返回游标

commit()       -------------------------------     提交当前事务

rollback()       -------------------------------     回滚当前事务

close()          --------------------------------    关闭连接

游标对象cursor有以下方法:

execute()      ---------------------------------    执行数据库查询和命令

fetchone()     ---------------------------------    取得结果集的下一行

fetchmany()   ---------------------------------    取得结果集的下几行

fetchall()        ---------------------------------    取得结果集中剩下的所有行

rowcount       ---------------------------------    最近一次execute()返回数据的行数或影响行数

close()           ---------------------------------    关闭游标对象

提交事务:当你操作了数据库(增删查改)之后,就一定要提交事务,不然你之前的操作不会有结果。

回滚事务:如果操作数据库出现异常的时候,就可以用回滚事务,使之恢复到没有操作数据库之前。

下面用代码来加深理解:

 1 #-*- coding:utf-8 -*-
 2 import  MySQLdb
 3
 4 con = MySQLdb.Connect(
 5     host = "你的数据库主机地址",
 6     user = "你的数据库用户名",
 7     passwd = "你的数据库密码",
 8     db = "你的数据库名",
 9     port = 3306,
10     charaet = "编码类型"
11
12 )
13
14 cur = con.cursor()

上面创建了连接对象,然后用连接对象创建了游标对象,步骤1、2就完成了。接着来操作数据库,这是我数据库一个表(user)的数据:

接着代码:

 1 sql = "select * from user"
 2 cur.execute(sql)
 3
 4 print cur.rowcount
 5
 6 print cur.fetchone()
 7
 8 print cur.fetchmany(1)
 9
10 print cur.fetchall()
11
12 cur.close()
13 con.close()

打印结果如下:

3
(u‘name1‘, u‘1‘)
((u‘name2‘, u‘2‘),)
((u‘name3‘, u‘3‘),)

我想代码不言而明,因为里面代码的一些方法在上面已经告知了用处。注意:操作完后要关闭游标对象和连接对象(用close()方法)

接着操作,增:

1 sql = ‘inser into user(username, password) values("name4","4")‘
2 cur.execute(sql)
3
4 cur.close()
5 con.close()

运行上面代码发现数据库并没有增加记录(自动提交已关闭),这时就要提交事务(用commit()方法),在上面代码的第三行加上这句代码:con.commit()并运行代码发现数据库添加了一条记录。如图:

-------------------接下来的改和删就不演示了,改下SQL语句就可以的,接下来看下回滚事务-------------------------------

 1 insert_sql = ‘insert into user(username, password) values("name5", "5")‘
 2 del_sql = "delete from user where word=‘5‘"
 3 try:
 4
 5     cur.execute(insert_sql)
 6
 7     cur.execute(del_sql)
 8
 9     con.commit()
10 except:
11     con.rollback()
12
13 cur.close()
14 con.close()

上面代码有两个SQL语句,一个是增加username=name5,password=5,一个是删除word字段等于5的记录,但是我的表中并没有word这个字段。所以增的语句会执行成功,删的语句会执行失败。我把执行这两条语句放到try块里,全部执行成功就提交事务,一旦哪条执行失败就捕获错误并回滚事务。运行了代码后发现,数据库不变。这里虽然增执行成功了,但在删执行失败了,就回滚了事务。所以回滚事务就恢复到了没有操作数据库之前(这里就是没有执行增之前),所以数据库的数据不变。

操作数据库并不难,只要你会SQL语句!

时间: 2024-10-28 23:48:31

Pyhton 操作MySQL数据库的相关文章

python操作mysql数据库

连接数据库 输入值 存入数据库 关闭 import string import mysql.connector conn=mysql.connector.connect(user='root',password='test',database='dalian',use_unicode=True) cursor=conn.cursor() a=raw_input('enter an id: ') b=raw_input('enter a name: ') while(a!='quit' or b!

Windows下安装MySQLdb, Python操作MySQL数据库的增删改查

这里的前提是windows上已经安装了MySQL数据库,且配置完毕,能正常建表能操作.在此基础上只需安装MySQL-python-1.2.4b4.win32-py2.7.exe就ok了,只有1M多.这个有点类似jdbc里的那个jar包. 下载链接:http://sourceforge.net/projects/mysql-python/ , 百度云盘 :http://pan.baidu.com/s/1dDgnfpR 密码:7bna 接着import MySQLdb就能使用了,下面给出测试代码:

使用python操作mysql数据库

这是我之前使用mysql时用到的一些库及开发的工具,这里记录下,也方便我查阅. python版本: 2.7.13 mysql版本: 5.5.36 几个python库 1.mysql-connector-python 是MySQL官方的Python驱动 https://dev.mysql.com/doc/connector-python/en/ 安装: pip install mysql-connector 示例代码: https://github.com/mike-zhang/pyExample

【php】php操作MySQL数据库

一.操作步骤: 1. 连接MySQL数据库并判断是否连接成功2. 选择数据库3. 设置字符集4. 准备SQL语句5. 向MySQL服务发送SQL语句6. 解析处理结果集7. 释放结果集,关闭数据库连接 二.常用操作: 1. mysqli_connect();--连接数据库,并返回一个连接资源 格式: mysql_connect(主机名,用户,密码); --其中参数可选,若不写则参考php.ini中默认配置 2. mysqli_error(); --获取刚刚(最后)执行数据库操作的错误信息 3.

python3操作MySQL数据库

安装PyMySQL 下载地址:https://pypi.python.org/pypi/PyMySQL 1.把操作Mysql数据库封装成类,数据库和表先建好 import pymysql.cursors # ======== Setting linked test databases =========== host = '192.168.17.123' user = 'root' password = '123456' db='polls' # ======== MySql base oper

c语言操作mysql数据库

c语言操作Mysql数据库,主要就是为了实现对数据库的增.删.改.查等操作,操作之前,得先连接数据库啊,而连接数据库主要有两种方法.一.使用mysql本身提供的API,在mysql的安装目录中可可以看到大量的头文件.lib文件.dll文件,这说明mysql原生就支持了c语言,操作起来相当简单.二.使用win32 api(这里只探讨windows平台),主要是ODBC. ODBC API 接口是(Open Database Connectivity)开放式数据库接口,它建立了一组规范,并提供了一组

PHP操作MySQL数据库的相关函数

首先,要分清SQL语句的类型: SQL语句的分类 (1)DDL:Data Define Language,数据定义语言--定义表的列结构 CREATE.DROP.ALTER.TRUNCATE (2)DML:Data Manipulate Language,数据操作语言--操作表的记录行 INSERT.DELETE.UPDATE (3)DQL:Data Query Language,数据查询语言--不影响表的行和列 SELECT (4)DCL:Data Control Language,数据控制语

本地通过Eclipse链接Hadoop操作Mysql数据库问题小结

前一段时间,在上一篇博文中描述了自己抽时间在构建的完全分布式Hadoop环境过程中遇到的一些问题以及构建成功后,通过Eclipse操作HDFS的时候遇到的一些问题,最近又想进一步学习学习Hadoop操作Mysql数据库的一些知识,在这里网上存在很多分歧,很多人可能会笑话,用那么“笨重”的Hadoop来操作数据库,脑子有问题吧,Hadoop的HDFS优势在于处理分布式文件系统,这种说法没有任何错误,数据库的操作讲究“安全.轻便.快捷”,用Hadoop操作完全是不符合常理啊,那为啥还要学习这个东西呢

mysqli扩展库操作mysql数据库

配置环境 配置php.ini文件让php支持mysqli扩展库 extension=php_mysqli.dll 建库建表 详见博客 “mysql扩展库操作mysql数据库” 查询数据库 1 <?php 2 //mysqli扩展库操作mysql数据库,面向对象 3 $mysqli=new MySQLi("localhost","root","root","test"); 4 if($mysqli->connect_