python -- peewee处理数据库连接
2016-12-13 15:06
459 查看
目前,实现了的Database子类有三个;SqliteDatabase、MySQLDatabase、PostgresqlDatabase
class SqliteDatabase(Database)
“sqlite3”模块驱动
class MySQLDatabase(Database)
“MySQLdb” 模块驱动
class PostgresqlDatabase(Database)
“psycopg2” 模块驱动
例如mysql数据库连接,新建文件mysql_db.py:(其它两种数据库连接类似)
其中database为mysql的Default Schema(默认数据库),kwargs为连接数据库的信息
格式如下:
ps: 可以运行mysql_db.py,测试数据库是否连接成功,结果如下:
<pymysql.connections.Connection object at 0x104c5d710>
然后新建一个操作数据库的python文件 db_utils.py
接下来,我们就可以对数据库进行操作了,新建一个test_db.py文件,如下所示:
运行test_db.py,可以打印出数据库查询结果,其它数据库操作均可使用该方法
class SqliteDatabase(Database)
“sqlite3”模块驱动
class MySQLDatabase(Database)
“MySQLdb” 模块驱动
class PostgresqlDatabase(Database)
“psycopg2” 模块驱动
例如mysql数据库连接,新建文件mysql_db.py:(其它两种数据库连接类似)
from peewee import * database = MySQLDatabase(database, **kwargs)
database.connect() print database.get_conn() class BaseModel(Model): class Meta: database = database
class TB1(BaseModel): id = BigIntegerField(primary_key=True) class Meta: db_table = 'tb1'
其中database为mysql的Default Schema(默认数据库),kwargs为连接数据库的信息
格式如下:
{'host': 'vpca-1.vm.elenet.me', 'password': '123456', 'port': 9707, 'user': 'vpca_user'}
ps: 可以运行mysql_db.py,测试数据库是否连接成功,结果如下:
<pymysql.connections.Connection object at 0x104c5d710>
然后新建一个操作数据库的python文件 db_utils.py
def select_sql(table, sql): query_result = table.get(sql) return query_result def select_all(table, sql): query_result = table.select().where(sql) return query_result def excute_sql(table, sql): query_result = table.raw(sql) return query_result.execute() def raw_sql(table, sql): query = table.raw(sql) return query
接下来,我们就可以对数据库进行操作了,新建一个test_db.py文件,如下所示:
import unittest from db_utils import excute_sql from mysql_db import TB1
class TestDB(unittest.TestCase): def setUp(self): self.select1 = "SELECT id FROM tb1 LIMIT 1" def test_select_sql(self): data = excute_sql(TB1, self.select1) for re in data: print re.id
运行test_db.py,可以打印出数据库查询结果,其它数据库操作均可使用该方法
相关文章推荐
- 数据库连接字符串的处理方法!加密解密连接字符串。
- asp.net2.0中关于ASP.NET 网站管理工具无法连接sql server 数据库的处理
- 数据库连接异常的处理思路
- 数据库SQLserver2005连接异常处理
- MySQL高效处理大量并发的数据库连接方法
- 正好整理了一下,自己做了个连接数据库的组件,支持SQLSERVER,ACCESS,ORACLE,FoxPro,MySql,IBM DB2,DBF等数据库,并且支持事务处理
- ADO连接数据库读取时_variant_t为空的处理
- 通过CouchDB-Python连接带有用户名/密码验证的数据库
- python连接数据库
- asp.net2.0中关于ASP.NET 网站管理工具无法连接sql server 数据库的处理
- python mysqldb连接数据库
- 数据库连接时一个异常的处理:java.sql.SQLException: No suitable driver found for
- asp.net2.0中关于ASP.NET 网站管理工具无法连接sql server 数据库的处理
- 网站无法连接sql sever数据库的一些问题处理,解决自己定义的数据库用户名,无法关联数据库和无法登陆数据库
- python使用mysqldb连接数据库
- 在WebSphere环境下如果没有正确处理数据库连接State:STATE_TRAN_WRAPPER_INUSE
- IBatis.Net学习笔记十--数据库连接处理
- python mysqldb连接数据库
- IBatis.Net学习笔记十--数据库连接处理 (转)
- hibernate 使用连接池连接数据库时 自动断开处理