疯狂老司机 2020-01-10
import pymysql #1). 创建数据库连接, autocommit是否自动提交修改到数据库中. conn = pymysql.connect(host=‘localhost‘, user=‘root‘, password=‘westos‘, db=‘Blog‘, port=3306, autocommit=True, charset=‘utf8‘) #2). 创建游标(用来执行sql语句的) cur = conn.cursor() #3). 执行sql语句 insert_sql = ‘insert into users(username) values ("user6");‘ cur.execute(insert_sql) print("插入数据成功.......") #4). 关闭游标 cur.close() #5).关闭连接 conn.close()
class Connection(object): def __enter__(self): Context manager that returns a Cursor warnings.warn( "Context manager API of Connection object is deprecated; Use conn.begin()", DeprecationWarning) return self.cursor() def __exit__(self, exc, value, traceback): On successful exit, commit. On exception, rollback(回滚) if exc: self.rollback() else: self.commit() import pymysql #使用with语句是, pymysql.connect返回的是数据库游标。(具体的内容查看源代码) with pymysql.connect(host=‘localhost‘, user=‘root‘, password=‘westos‘, db=‘Blog‘, port=3306, autocommit=True, charset=‘utf8‘) as cur: #3). 执行sql语句(增删改) insert_sql = ‘insert into users(username) values ("user7");‘ cur.execute(insert_sql) print("插入数据成功.......")
import pymysql users = [(‘redhat‘ + str(i), ‘passwd‘+str(i)) for i in range(100)] #users = [(‘redhat1‘, ‘passwd1‘), (‘redhat2‘, ‘passwd2‘), .......] #使用with语句是, pymysql.connect返回的是数据库游标。(具体的内容查看源代码) with pymysql.connect(host=‘localhost‘, user=‘root‘, password=‘westos‘, db=‘Blog‘, port=3306, autocommit=True, charset=‘utf8‘) as cur: #3). 执行sql语句(增删改) insert_sql = ‘insert into users(username, password) values (%s, %s);‘ #execute: 执行一条sql语句。 #executemany: 执行多条sql语句。 #‘insert into users(username, password) values (%s, %s);‘ %users[0] #‘insert into users(username, password) values (%s, %s);‘ %(‘redhat1‘, ‘passwd1‘) #‘insert into users(username, password) values (%s, %s);‘ %users[1] #‘insert into users(username, password) values (%s, %s);‘ %users[2] cur.executemany(insert_sql, users) print("插入数据成功.......")
import pymysql with pymysql.connect(host=‘localhost‘, user=‘root‘, password=‘westos‘, db=‘Blog‘, port=3306, autocommit=True, charset=‘utf8‘) as cur: #3). 执行sql语句(增删改) query_sql = ‘select * from users where username like "user%";‘ #Number of affected rows result = cur.execute(query_sql) print("符合条件的记录数: ", result) #print(cur.fetchone()) #print(cur.fetchmany(2)) users_info = cur.fetchall() #以表格方式美观的打印。 from prettytable import PrettyTable pt = PrettyTable(field_names=[‘编号‘, ‘用户名‘, ‘密码‘]) for user in users_info: pt.add_row(user) print(pt)
1. 什么是sqlite数据库? SQLite是内嵌在Python中的轻量级、基于磁盘文件袋额数据库管理系统(就是一个文件), 不需要安装和配置服务,支持使用SQL语句来访问数据库。该数据库使用C语言开发,支持大多数SQL91标准, 支持原子的、一致的、独立的和持久的事务,不支持外键限制;通过数据库级的独占性和共享性锁定来实现独立事务, 当多个线程同时访问同一个数据库并试图写入数据时,每一时刻只有一个线程可以写入数据。 2. sqlite数据库的特性: SQLite支持最大140TB大小的单个数据库,每个数据库完全存储在单个磁盘文件中, 以B+树数据结构的形式存储,一个数据库就是一个文件,通过直接复制数据库文件就可以实现数据库的备份。 如果需要使用可视化管理工具,可以下载并使用SQLiteManager、SQLite Database Browser 或其他类似工具。 import sqlite3 #1). 创建连接 conn = sqlite3.connect(database=‘users.sqlite‘) #2). 创建游标 cur = conn.cursor() #3). 操作 #if not exists如果数据库标不存在时创建表,否则不做操作。 create_sql = ‘create table if not exists userinfo1 (id int auto_increment primary key , name varchar(10) unique, passwd varchar(10) default "123");‘ cur.execute(create_sql) insert_sql = ‘insert into userinfo1(name) values("user2");‘ cur.execute(insert_sql) #数据操作(增删改)一定需要提交。 conn.commit() select_sql = ‘select * from userinfo1‘ cur.execute(select_sql) print("查询结果: ", cur.fetchall()) cur.close() conn.close()
什么是ORM?
ORM,即Object-Relational Mapping(对象关系映射),它的作用是在关系型数据库和
业务实体对象之间作一个映射,这样,我们在具体的操作业务对象的时候,就不需要再
去和复杂的SQL语句打交道,只需简单的操作对象的属性和方法。
安装sqlalchemy
import sqlalchemy from sqlalchemy import Column, Integer, String from sqlalchemy.ext.declarative import declarative_base import pymysql pymysql.install_as_MySQLdb() #object(oop) ---> mysql(SQL) #1). 创建数据库引擎(连接数据库的过程) #echo=True显示翻译好的SQL语句。 from sqlalchemy.orm import Session, sessionmaker engine = sqlalchemy.create_engine("mysql://root:/Blog", encoding=‘utf8‘, echo=True) #2). 建立缓存 session = sessionmaker(bind=engine)() #3). 创建数据库对象需要继承的基类 Base = declarative_base() #4). 创建类, 一个类就是一个数据库表 class Student(Base): # 数据库表的名称 __tablename__ = ‘student_info‘ #数据库表的属性信息 id = Column(Integer, primary_key=True, autoincrement=True) name = Column(String(20)) sex = Column(String(10)) #def __repr__(self): #return ‘Student<%s>‘ %(self.name) if __name__ == ‘__main__‘: # 根据设置的信息创建数据库表-(创建类:创建数据库表的过程) Base.metadata.create_all(engine) #添加数据信息(实例化对象: 添加一条数据/记录) #INSERT INTO student_info (id, name, sex) VALUES (%(id)s, %(name)s, %(sex)s) stu1 = Student(id=2, name=‘westos2‘, sex=‘男‘) #stu2 = Student(id=3, name=‘westos3‘, sex=‘男‘) #stu3 = Student(id=4, name=‘westos4‘, sex=‘女‘) session.add_all([stu1, ]) session.commit() #查询数据信息 print(session.query(Student).all()) #根据筛选条件查询信息 print(session.query(Student).filter_by(name=‘westos1‘).all()) print(session.query(Student).filter_by(name=‘westos1‘).first()) print(session.query(Student).filter_by(name=‘westoshdhwhdewd‘).first()) #删除数据 stu1 = session.query(Student).filter_by(name=‘westos2‘).first() print("before delete: ", stu1) session.delete(stu1) session.commit() stu1 = session.query(Student).filter_by(name=‘westos1‘).first() print("after delete: ", stu1)