python pymysql和orm，,pymsql是Pyt

pymsql是Python中操作MySQL的模块，其使用方法和MySQLdb几乎相同。

1. 安装

管理员打开cmd，切换到python的安装路径，进入到Scripts目录下（如：C:\Users\Administrator\AppData\Local\Programs\Python\Python35\Scripts）；

执行以下命令：pip install pymysql

校验是否安装成功：进入到python命令行模式，输入import pymysql，无报错代表成功；

2. 使用操作

2.1 查询数据

import pymysql#创建链接conn = pymysql.connect(host=‘127.0.0.1‘, port=3306, user=‘root‘, passwd=‘123123‘, db=‘t1‘)#创建游标cursor = conn.cursor()#执行sqlcursor.execute("select * from students")   # 获取第一行数据row_1 = cursor.fetchone()   # 获取前n行数据row_2 = cursor.fetchmany(3)# 获取所有数据row_3 = cursor.fetchall()# 提交，不然无法保存新建或者修改的数据conn.commit()#关闭游标cursor.close()#关闭链接conn.close()

2.2 执行sql

import pymysql   # 创建连接conn = pymysql.connect(host=‘127.0.0.1‘, port=3306, user=‘root‘, passwd=‘123123‘, db=‘t1‘)# 创建游标cursor = conn.cursor()   # 执行SQL，并返回收影响行数effect_row = cursor.execute("update hosts set host = ‘1.1.1.2‘")   # 执行SQL，并返回受影响行数#effect_row = cursor.execute("update hosts set host = ‘1.1.1.2‘ where nid > %s", (1,))   # 执行SQL，并返回受影响行数#effect_row = cursor.executemany("insert into hosts(host,color_id)values(%s,%s)", [("1.1.1.11",1),("1.1.1.11",2)])      # 提交，不然无法保存新建或者修改的数据conn.commit()   # 关闭游标cursor.close()# 关闭连接conn.close()

三. ORM sqlachemy

1.对象映射关系（ORM）

orm英文全称object relational mapping,就是对象映射关系程序，简单来说我们类似python这种面向对象的程序来说一切皆对象，但是我们使用的数据库却都是关系型的，为了保证一致的使用习惯，通过orm将编程语言的对象模型和数据库的关系模型建立映射关系，这样我们在使用编程语言对数据库进行操作的时候可以直接使用编程语言的对象模型进行操作就可以了，而不用直接使用sql语言。

优点：

缺点：

2. SQLAlchemy

在Python中，最有名的ORM框架是SQLAlchemy。用户包括openstack＼Dropbox等知名公司或应用

Dialect用于和数据API进行交流，根据配置文件的不同调用不同的数据库API，从而实现对数据库的操作，如：

MySQL-Python    mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>     pymysql    mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>]     MySQL-Connector    mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname>     cx_Oracle    oracle+cx_oracle://user:[email protected]:port/dbname[?key=value&key=value...]     更多详见：http://docs.sqlalchemy.org/en/latest/dialects/index.html

　　注：支持连接MySQL、Oracles数据库

2.1 安装：

pip install SQLAlchemypip install pymysql#由于mysqldb依然不支持py3，所以这里我们用pymysql与sqlalchemy交互

2.2 基本使用：

下面就开始让你见证orm的nb之处，盘古开天劈地之前，我们创建一个表是这样的：

CREATE TABLE user (    id INTEGER NOT NULL AUTO_INCREMENT,    name VARCHAR(32),    password VARCHAR(64),    PRIMARY KEY (id))

这只是最简单的sql表，如果再加上外键关联什么的，一般程序员的脑容量是记不住那些sql语句的，于是有了orm,实现上面同样的功能，代码如下：

import sqlalchemyfrom sqlalchemy import create_enginefrom sqlalchemy.ext.declarative import declarative_basefrom sqlalchemy import Column, Integer, String  engine = create_engine("mysql+pymysql://root:alex3[email protected]/testdb",                                    encoding=‘utf-8‘, echo=True)    Base = declarative_base() #生成orm基类  class User(Base):    __tablename__ = ‘user‘ #表名    id = Column(Integer, primary_key=True)    name = Column(String(32))    password = Column(String(64))  Base.metadata.create_all(engine) #创建表结构

最基本的表我们创建好了，那我们开始用orm创建一条数据试试

Session_class = sessionmaker(bind=engine) #创建与数据库的会话session class ,注意,这里返回给session的是个class,不是实例Session = Session_class() #生成session实例    user_obj = User(name="cc",password="123123") #生成你要创建的数据对象print(user_obj.name,user_obj.id)  #此时还没创建对象呢，不信你打印一下id发现还是None  Session.add(user_obj) #把要创建的数据对象添加到这个session里， 一会统一创建print(user_obj.name,user_obj.id) #此时也依然还没创建  Session.commit() #现此才统一提交，创建数据

2.2.1 查询

my_user = Session.query(User).filter_by(name="cc").first()print(my_user) #打印输出：<__main__.User object at 0x105b4ba90>print(my_user.id,my_user.name,my_user.password)#打印输出：cc 123123

print(Session.query(User.name,User.id).all() )　　#获取所有数据
objs=Session.query(User).filter(User.id>0).filter(User.id<7).all() #多条件查询

Session.query(User).filter(User.name.like("Ra%")).count() #统计

fromsqlalchemyimportfunc

def __repr__(self):    return "<User(name=‘%s‘,  password=‘%s‘)>" % (        self.name, self.password)

my_user = Session.query(User).filter_by(name="cc").first()  my_user.name = "TT"  Session.commit()

my_user = Session.query(User).filter_by(id=1).first()my_user.name = "Jack"    fake_user = User(name=‘Rain‘, password=‘12345‘)Session.add(fake_user)  print(Session.query(User).filter(User.name.in_([‘Jack‘,‘rain‘])).all() )  #这时看session里有你刚添加和修改的数据  Session.rollback() #此时你rollback一下  print(Session.query(User).filter(User.name.in_([‘Jack‘,‘rain‘])).all() ) #再查就发现刚才添加的数据没有了。  # Session# Session.commit()

from sqlalchemy import create_enginefrom sqlalchemy.ext.declarative import declarative_basefrom sqlalchemy import String,Column,Integer,ForeignKey,DATEfrom sqlalchemy.orm import sessionmaker,relationship  engine = create_engine("mysql+pymysql://root:[email protected]@192.168.1.18/testdb",                       encoding="utf-8")  Base = declarative_base()  class Student(Base):    __tablename__ ="student"    id = Column(Integer,primary_key=True)    name = Column(String(32),nullable=False)    register_date = Column(DATE,nullable=False)      def __repr__(self):        return "<%s name:%s>"%(self.id,self.name)  class StudyRecord(Base):    __tablename__ = "study_record"    id = Column(Integer,primary_key=True)    day = Column(Integer,nullable=False)    status = Column(String(32),nullable=False)    stu_id = Column(Integer,ForeignKey("student.id")) #关联student表里的id      my_student = relationship("Student",backref="my_study_record") # Student为关联的类def __repr__(self):        return "<%s name:%s>" % (self.id, self.name)  Base.metadata.create_all(engine)  Session_class = sessionmaker(bind=engine)session = Session_class()  s1 = Student(name="cc",register_date="2016-10-28")s2 = Student(name="tt",register_date="2015-10-28")s3 = Student(name="RR",register_date="2014-10-28")s4 = Student(name="YY",register_date="2013-10-28")  r1 = StudyRecord(day=1,status="YES",stu_id=1)r2 = StudyRecord(day=2,status="No",stu_id=1)r3 = StudyRecord(day=3,status="YES",stu_id=1)r4 = StudyRecord(day=1,status="YES",stu_id=2)  session.add_all([s1,s2,s3,s4,r1,r2,r3,r4])session.commit()