pesto 正在参加 2020 年度 OSC 中国开源项目评选,请投票支持!
pesto 在 2020 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
投票让它出道
已投票
授权协议 Apache
开发语言 Python
操作系统 跨平台
软件类型 开源软件
开发厂商
地区 国产
提 交 者 Dreampie
适用人群 未知
收录时间 2020-05-25

软件简介

Python下的极简orm框架,核心思想,领域对象+仓库

1、特色

1、自动化的模型结构映射,不需要复杂的创建数据模型和数据库表结构直接的映射信息,只需要一个简单的继承就可以实现属性自动映射

class Example(MysqlBaseModel):
    def __init__(self):
        super(Example, self).__init__(table_name='example')
        
#使用
example= Example()
...
example.save() #对象的增删改查 轻松实现

2、超轻量级的配置初始化,只需要在 config.ini 配置对应的数据库信息,自动初始化连接,随时随地的执行sql

3、简单实用的日志工具

# 配置 config.ini
log.path = /opt/logs/pesto-orm/pesto-orm.log
log.level = INFO

# 使用简单
logger = LoggerFactory.get_logger('dialect.mysql.domain')

4、支持数据库事务

#一个注解告别,python下的事务烦恼
@transaction()
def methodX():
    pass

5、环境隔离的参数配置工具 config.ini, 公共参数放default,定制参数放在各自的环境

[default]

[dev]

[test]

[prod]

6、等等

2、结构

领域对象:领域模型对应的属性和行为

仓库:批量操作领域对象,或者特殊的一些数据操作逻辑

领域服务:统筹领域模型的行为,或者更复杂的单个模型无法完成的行为

只需要配置数据库相关的参数,通过领域模型,或者仓库即可操作数据,简单易用,业务逻辑复杂可以加入领域服务概念

3、示例

pesto-example(flask + pesto-orm) build in python 3.6

add dependencies in requirements(重要):

pesto-orm==0.0.1
mysql-connector-python==8.0.11
Flask==1.0.2

add config in config.ini(重要):

[DEFAULT]
app.key = pesto-orm
log.path = /opt/logs/pesto-orm/pesto-orm.log
log.level = INFO
; db config 目前只支持mysql,欢迎提交其他数据库的实现
db.database = example
db.raise_on_warnings = True
db.charset = utf8mb4
db.show_sql = True

; profiles config for env
[local]

db.user = root
db.password =
db.host = 127.0.0.1
db.port = 3306

[dev]

[test]

[prod]

run with env(default is local, dev, test, prod)

env=$ENV python ./pesto_example/main.py >> std_out.log 2>&1

main 示例example,可以直接执行main方法启动(需先执行数据库的创建,以及配置数据的相关信息)

@app.route('/')
def index():
    data = {'name': 'pesto-example'}
    return jsonify(data)


if __name__ == '__main__':
    port = 8080
    try:
        app.run(host='0.0.0.0', port=port)
    except (KeyboardInterrupt, SystemExit):
        print('')
        logger.info('Program exited.')
    except (Exception,):
        logger.error('Program exited. error info:\n')
        logger.error(traceback.format_exc())
        sys.exit(0)

model 模型创建,只需要配置对应的表名和主键,领域模型的行为可以扩展到该类

class Example(MysqlBaseModel):
    def __init__(self):
        super(Example, self).__init__(table_name='example', primary_key='id')

repository 依赖于模型,执行批量或者复杂的sql逻辑

class ExampleRepository(MysqlBaseRepository):
    def __init__(self):
        super(ExampleRepository, self).__init__(Example)

router api的路由信息,数据操作方式

app_example = Blueprint('example', __name__, url_prefix='/examples')

example_repository = ExampleRepository()


@app_example.route('', methods=['GET'])
def examples():
    # 条件查询
    data = example_repository.query_by(where="")
    if len(data) <= 0:
        jsonify(error="not found any data"), 404

    return jsonify(data)


@app_example.route('/<id>', methods=['GET'])
def example(id):
    # 条件查询
    data = example_repository.query_first_by(where="`id`= %s", params=(id,))
    if data is None:
        jsonify(error="not found any data"), 404

    return jsonify(data)


@app_example.route('', methods=['POST'])
def save():
    data = request.get_json()
    if data is not None and len(data) > 0:
        example = Example()
        example.set_attrs(data)
        example.created_at = datetime.datetime.now()
        example.updated_at = datetime.datetime.now()
        # 保存数据
        example.save()
        return jsonify(example.id)
    else:
        return jsonify(error="not found any data to save"), 400


@app_example.route('/<id>', methods=['DELETE'])
def delete(id):
    result = True
    example = Example()
    example.id = id
    example.deleted_at = datetime.datetime.now()
    # 根据id删除数据
    example.delete()
    return jsonify(result)


@app_example.route('/<id>', methods=['PUT'])
def update(id):
    result = True
    data = request.get_json()
    example = Example()
    example.set_attrs(data)
    example.id = id
    example.updated_at = datetime.datetime.now()
    # 根据id更新数据
    example.update()
    return jsonify(result)

创建数据库

create database example;

create table example(
    id INT UNSIGNED AUTO_INCREMENT,
    title VARCHAR(255) NOT NULL,
    created_at DATETIME NOT NULL,
    updated_at DATETIME NOT NULL,
    deleted_at DATETIME NOT NULL,
    PRIMARY KEY(id)
    )ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

4、测试

# 查询全部数据
curl -X GET \
  http://localhost:8080/examples

# 添加一条数据
curl -X POST \
  http://localhost:8080/examples \
  -H 'content-type: application/json' \
  -d '{
	"title":"第三个测试"
}'

# 根据id查询
curl -X GET \
  http://localhost:8080/examples/1
  
# 根据id 更新数据
curl -X PUT \
  http://localhost:8080/examples/1 \
  -H 'content-type: application/json' \
  -d '{
	"title":"这是第一个已改测试"
}'

# 根据id删除数据
curl -X DELETE \
  http://localhost:8080/examples/3

地址:

https://gitee.com/dreampie/pesto

https://github.com/Dreampie/pesto

 

展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (0)

加载中
更多评论
暂无内容
发表了博客
05/22 17:37

Minimalist python orm framework(python orm/utils)

Python ORM and Utils python下的极简orm框架,核心思想,领域对象+仓库 地址: https://gitee.com/dreampie/pesto https://github.com/Dreampie/pesto 1、特色 1、自动化的模型结构映射,不需要复杂的创建数据模......

0
0
发表于数据库专区
04/29 22:40

腾讯招聘3位大数据开发工程师

30359-灯塔-大数据集群开发工程师(Cloudera、HDP产品系统产品) 工作地点:北京 职位类别:技术类 工作年限:三年以上 招聘人数:3人 岗位职责: 负责PCG灯塔构建多引擎融合平台 1、各类引擎融合架构设计、预研落...

0
0
发表于软件架构专区
2015/05/26 11:45

The turnover of pizzas

The turnover of pizzas

0
0
01/20 09:30

ElasticSearch 倒排索引简析

内容概要 倒排索引是什么?为什么需要倒排索引? 倒排索引是怎么工作的? 1. 倒排索引是什么? 假设有一个交友网站,信息表如下: 美女1:“我要找在上海做 PHP 的哥哥。” 需要匹配 性别、城市、语言列。 美女2...

0
0
发表了博客
01/22 19:58

Elasticsearch 倒排索引

Elasticsearch Elasticsearch 是一个实时的分布式存储,搜索,分析的搜索引擎。 主要特性 轻量快速的全文搜索。 安全分析和基础设施监控。 支持海量规模,数千台服务器、PB级数据量。 可以集成可视化数据分析工具...

0
0
发表了博客
08/24 11:05

Web 测试

一、电子商务站点的基本结构 1. 电商平台的标准架构 相关概念: SEO Search Engine Optimization,搜索引擎优化。 SEO 是指从自然搜索结果获得网站流量的技术和过程,是在了解搜索引擎自 然排名机制的基础上,对网站进行内部及外部的调整优化,改进网站在搜索引 擎中的关键词自然排名,获得更多流量,从而达成网站销售及...

0
0
发表了博客
01/21 15:01

「扫盲」 Elasticsearch

什么是Elasticsearch? Elasticsearch is a real-time, distributed storage, search, and analytics engine Elasticsearch 是一个实时的分布式存储、搜索、分析的引擎。 介绍那儿有几个关键字: 实时、分布式、搜......

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
暂无内容
0 评论
5 收藏
分享
返回顶部
顶部