菜单

Mysql数据库的接口MySQLdb

2019年10月2日 - 数据库

这样就表示MySQL运行成功。

fname=Mac,lname=Mohan,age=20,sex=M,income=2000

您可能感兴趣的文章:

Python 数据库接口支持非常多的数据库,你可以选择适合你项目的数据库:
GadFly mSQL MySQL…

python操作mysql数据库

Python 标准数据库接口为 Python DB-API,Python
DB-API为开发人员提供了数据库应用编程接口。

Python 数据库接口支持非常多的数据库,你可以选择适合你项目的数据库:

        再修改密码的长度

#执行SQL语句

Python连接mysql数据库的正确姿势,pythonmysql数据库

Python 数据库接口支持非常多的数据库,你可以选择适合你项目的数据库:

不同的数据库你需要下载不同的DB
API模块,例如你需要访问Oracle数据库和Mysql数据,你需要下载Oracle和MySQL数据库模块。

DB-API 是一个规范. 它定义了一系列必须的对象和数据库存取方式,
以便为各种各样的底层数据库系统和多种多样的数据库接口程序提供一致的访问接口

Python的DB-API,为大多数的数据库实现了接口,使用它连接各数据库后,就可以用相同的方式操作各数据库。

Python DB-API使用流程:

一、什么是MySQLdb?

MySQLdb 是用于Python链接Mysql数据库的接口,它实现了 Python 数据库 API
规范 V2.0,基于 MySQL C API 上建立的。

二、如何安装MySQLdb?

为了用DB-API编写MySQL脚本,必须确保已经安装了MySQL。复制以下代码,并执行:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

如果执行后的输出结果如下所示,意味着你没有安装 MySQLdb 模块:

Traceback (most recent call last):
 File "test.py", line 3, in <module>
  import MySQLdb
ImportError: No module named MySQLdb

如果您选择二进制文件发行版本的话,安装过程基本安装提示即可完成。如果从源代码进行安装的话,则需要切换到MySQLdb发行版本的顶级目录,并键入下列命令:

$ gunzip MySQL-python-1.2.2.tar.gz
$ tar -xvf MySQL-python-1.2.2.tar
$ cd MySQL-python-1.2.2
$ python setup.py build
$ python setup.py install

注意:请确保您有root权限来安装上述模块。

三、数据库连接

连接数据库前,请先确认以下事项:

实例:

以下实例链接Mysql的TESTDB数据库:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","codecloud","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 使用execute方法执行SQL语句
cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法获取一条数据库。
data = cursor.fetchone()

print "Database version : %s " % data

# 关闭数据库连接
db.close()

执行以上脚本输出结果如下:

Database version : 5.0.45

四、创建数据库表

如果数据库连接存在我们可以使用execute()方法来为数据库创建表,如下所示创建表EMPLOYEE:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","codecloud","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# 如果数据表已经存在使用 execute() 方法删除表。
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 创建数据表SQL语句
sql = """CREATE TABLE EMPLOYEE (
     FIRST_NAME CHAR(20) NOT NULL,
     LAST_NAME CHAR(20),
     AGE INT, 
     SEX CHAR(1),
     INCOME FLOAT )"""

cursor.execute(sql)

# 关闭数据库连接
db.close()

五、数据库插入操作

以下实例使用执行 SQL INSERT 语句向表 EMPLOYEE 插入记录:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","codecloud","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
     LAST_NAME, AGE, SEX, INCOME)
     VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
  # 执行sql语句
  cursor.execute(sql)
  # 提交到数据库执行
  db.commit()
except:
  # Rollback in case there is any error
  db.rollback()

# 关闭数据库连接
db.close()

以上例子也可以写成如下形式:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","codecloud","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 插入语句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
    LAST_NAME, AGE, SEX, INCOME) \
    VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
    ('Mac', 'Mohan', 20, 'M', 2000)
try:
  # 执行sql语句
  cursor.execute(sql)
  # 提交到数据库执行
  db.commit()
except:
  # 发生错误时回滚
  db.rollback()

# 关闭数据库连接
db.close()

实例:

以下代码使用变量向SQL语句中传递参数:

..................................
user_id = "test123"
password = "password"

con.execute('insert into Login values("%s", "%s")' % \
       (user_id, password))
..................................

六、数据库查询操作

Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall()
方法获取多条数据。

实例:

查询EMPLOYEE表中salary(工资)字段大于1000的所有数据:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","codecloud","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \
    WHERE INCOME > '%d'" % (1000)
try:
  # 执行SQL语句
  cursor.execute(sql)
  # 获取所有记录列表
  results = cursor.fetchall()
  for row in results:
   fname = row[0]
   lname = row[1]
   age = row[2]
   sex = row[3]
   income = row[4]
   # 打印结果
   print "fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
       (fname, lname, age, sex, income )
except:
  print "Error: unable to fecth data"

# 关闭数据库连接
db.close()

以上脚本执行结果如下:

fname=Mac, lname=Mohan, age=20, sex=M, income=2000

七、数据库更新操作

更新操作用于更新数据表的的数据,以下实例将 TESTDB表中的 SEX
字段全部修改为 ‘M’,AGE 字段递增1:

#!/usr/bin/python
# -*- coding: UTF-8 -*-

import MySQLdb

# 打开数据库连接
db = MySQLdb.connect("localhost","codecloud","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1
             WHERE SEX = '%c'" % ('M')
try:
  # 执行SQL语句
  cursor.execute(sql)
  # 提交到数据库执行
  db.commit()
except:
  # 发生错误时回滚
  db.rollback()

# 关闭数据库连接
db.close()

执行事务

事务机制可以确保数据一致性。

事务应该具有4个属性:原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。

Python DB API 2.0 的事务提供了两个方法 commit 或 rollback。

实例:

# SQL删除记录语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
  # 执行SQL语句
  cursor.execute(sql)
  # 向数据库提交
  db.commit()
except:
  # 发生错误时回滚
  db.rollback()

对于支持事务的数据库,
在Python数据库编程中,当游标建立之时,就自动开始了一个隐形的数据库事务。

commit()方法游标的所有更新操作,rollback()方法回滚当前游标的所有操作。每一个方法都开始了一个新的事务。

错误处理

DB API中定义了一些数据库操作的错误及异常,下表列出了这些错误和异常:

图片 1

以上就是本文的全部内容,希望对大家的学习有所帮助。

python操作mysql数据库

(ALTER等可以写成小写)

cursor.execute(sql)

  python2.*版本可以使用MySQLdb,不过不支持python3,python3中有一个pymysql,详细安装方法见这里

实例:

mysql> set global validate_password_policy=0;

print”Error: unable to fecth data”

不报错就证明模块安装完成

如何安装MySQLdb?

一:开发环境的配置

注意:请确保您有root权限来安装上述模块。

此密码加密过,可以复制,后面直接用

#打开数据库连接

1:桌面环境为cnetos7+python2.7

执行事务

mysql> select @@log_error;
ERROR 1820 (HY000): You must reset your password using ALTER USER statement before executing this statement.
mysql>

#关闭数据库连接

set global validate_password_length=1;

以下实例使用执行SQL INSERT语句向表EMPLOYEE插入记录:

ALTER USER 'root'@'localhost' IDENTIFIED BY 'root123';

LAST_NAME, AGE, SEX, INCOME)

3:python操作MySQL数据库

try:

        如何解决ERROR 1819 (HY000): Your password does not satisfy the current policy requirements呢?

db=MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB”)

4:数据库连接

事务机制可以确保数据一致性。

age=row[2]

·在你的机子上已经安装了Python MySQLdb模块。

用该密码登录到服务端后,必须马上修改密码再执行一些数据库操作,不然会报如下错误:

cursor.execute(sql)

db.close()

        再次执行修改密码就可以了

·rowcount:这是一个只读属性,并返回执行execute()方法后影响的行数。

  MySQLdb 是用于Python链接Mysql数据库的接口,它实现了 Python 数据库
API 规范 V2.0,基于 MySQL C API 上建立的。

AGE INT,

数据库更新操作

grep 'temporary password' /var/log/mysqld.log

(如果之前安装过MySQL则这里可能会有多个密码,用最后一个,注意这个密码输入时是可以粘贴的)

$ python setup.py build

为了加强安全性,MySQL5.7为root用户随机生成了一个密码,在error
log中,关于error
log的位置,如果安装的是RPM包,则默认是/var/log/mysqld.log。只有启动过一次mysql才可以查看临时密码

# -*- coding: UTF-8 -*-

一定要注意这蛋疼的大小写

results=cursor.fetchall()

DataError

#使用cursor()方法获取操作游标

图片 2

commit()方法游标的所有更新操作,rollback()方法回滚当前游标的所有操作。每一个方法都开始了一个新的事务。

 

# SQL删除语句

ERROR 1819 (HY000): Your password does not satisfy the current policy requirements

db.commit()

  1)MySQL的安装

except:

Database version : 5.0.45

当有数据处理时的错误发生时触发,例如:除零错误,数据超范围等等。必须是DatabaseError的子类。

        必须修改两个全局参数:
        首先,修改validate_password_policy参数的值

cursor.execute(sql)

连接数据库前,请先确认以下事项:

sql=”DELETE FROM EMPLOYEE WHERE AGE >

2:MySQL的安装与配置

# -*- coding: UTF-8 -*-

图片 3

cursor=db.cursor()

#!/usr/bin/python

db=MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB”)

(这是一个MySQL的以密码登录root用户的命令)

事务应该具有4个属性:原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。

执行以下脚本输出结果:

sex=row[3]

#!/usr/bin/python

SEX CHAR(1),

db.commit()

以下实例链接Mysql的TESTDB数据库:

sql=”DELETE FROM EMPLOYEE WHERE AGE >

数据库插入操作

db.rollback()

is any error

#打开数据库连接

FIRST_NAMECHAR(20) NOT NULL,

#发生错误时回滚

对于支持事务的数据库,在Python数据库编程中,当游标建立之时,就自动开始了一个隐形的数据库事务。

(fname,lname,age,sex,income)

# -*- coding: UTF-8 -*-

VALUES (‘%s’, ‘%s’, ‘%d’, ‘%c’, ‘%d’)”%\

InternalError

con.execute(‘insert into Login values(“%s”,

$ tar-xvfMySQL-python-1.2.2.tar

db.rollback()

#创建数据表SQL语句

Error

db=MySQLdb.connect(“localhost”,”testuser”,”test123″,”TESTDB”)

# SQL删除记录语句

相关文章

发表评论

电子邮件地址不会被公开。 必填项已用*标注

网站地图xml地图