开发者社区> JoanKing> 正文

Python mini-web框架7:元类实现ORM

简介: Python mini-web框架7:元类实现ORM
+关注继续查看

一、ORM是什么?



  • ORM 是 python编程语言后端web框架 Django的核心思想,“Object Relational Mapping”,即对象-关系映射,简称ORM。
  • 一个句话理解就是:创建一个实例对象,用创建它的类名当做数据表名,用创建它的类属性对应数据表的字段,当对这个实例对象操作时,能够对应MySQL语句




image.png


  • 看下面例子描述:


class User(父类省略):
     uid = ('uid', "int unsigned")
     name = ('username', "varchar(30)")
     email = ('email', "varchar(30)")
     password = ('password', "varchar(30)")
     ...省略...
u = User(uid=12345, name='Michael', email='test@orm.org', password='my-pwd')
u.save()
# 对应如下sql语句
# insert into User (username,email,password,uid)
# values ('Michael','test@orm.org','my-pwd',12345)


说明:

  • 所谓的ORM就是让开发者在操作数据库的时候,能够像操作对象时通过xxxx.属性=yyyy一样简单,这是开发ORM的初衷
  • 只不过ORM的实现较为复杂,Django中已经实现了 很复杂的操作,本节知识 主要通过完成一个 insert相类似的ORM,理解其中的道理就就可以了


二、通过元类简单实现ORM中的insert功能



  • 2.1、看下面一个例子


class ModelMetaclass(type):
      def __new__(cls, name,bases,attrs):
           mappings = dict()
           # 判断是否需要保存
           for k,v in attrs.items():
                # 判断是否是指定的 StringField 或者 IntegerField的实例对象
                if isinstance(v,tuple):
                      # print('Found mapping: %s ==> %s'%(k,v))
                      mappings[k] = v
           # 删除这些已经在字典中的属性
           for k in mappings.keys():
                 attrs.pop(k)
           # 将之前的uid/name/email/password 以及对应的对象引用、类名字
          attrs['__mappings__'] = mappings # 保持属性和列的映射关系
          attrs['__table__'] = name # 假设表名和类名一致
          return  type.__new__(cls,name,bases,attrs)
class User(metaclass=ModelMetaclass):
         uid = ('uid',"int unsigned")
         name = ('username',"varchar(30)")
         email = ('email',"varchar(30)")
         password = ('password',"varchard(30)")
         # 当指定元类之后,以上的类属性将不在类中,而是在__mappings__属性指定的字典中存储
         # 以上User类中有 
         # __mappings__ = {
         #     "uid": ('uid', "int unsigned")
         #     "name": ('username', "varchar(30)")
         #     "email": ('email', "varchar(30)")
         #     "password": ('password', "varchar(30)")
         # }
         # __table__ = "User"
         def __init__(self,**kwargs):
             for name,value in kwargs.items():
                  setattr(self,name,value)
         def save(self):
                  field = []
                  args = []
                  for k,v in self.__mappings__.items():
                       field.append(v[0])
                       args.append(getattr(self,k,None))
                  sql = 'insert into %s (%s) values (%s)'%(self.__table__,','.join(field),','.join([str(i) for i in args]))
                  print("SQL: %s"%sql)
u = User(uid=12345, name='Michael', email='test@orm.org', password='my-pwd')
# print(u.__dict__)
u.save()
  • 打印结果如下:


SQL: insert into User (uid,username,email,password) values (12345,Michael,test@orm.org,my-pwd)

提示:从是上面的打印我们可以看到 values后面括号中的value是有问题的,有些不是int类型,是字符串类型,在执行 sql 语句的时候会报错的,在下面我们把它的类型判断一下,进行完善


  • 2.2、完善对数据类型的检测,重写上面的 save() 方法,如下


def save(self):
    fields = []
    args = []
    for k, v in self.__mappings__.items():
         fields.append(v[0])
         args.append(getattr(self, k, None))
    args_temp = list()
    for temp in args:
        # 判断入如果是数字类型
        if isinstance(temp, int):
            args_temp.append(str(temp))
        elif isinstance(temp, str):
            args_temp.append("""'%s'""" % temp)
    sql = 'insert into %s (%s) values (%s)' % (self.__table__, ','.join(fields), ','.join(args_temp))
    print('SQL: %s' % sql)
u = User(uid=12345, name='Michael', email='test@orm.org', password='my-pwd')
# print(u.__dict__)
u.save()
  • 运行效果入下:


SQL: insert into User (email,uid,password,username) values ('test@orm.org',12345,'my-pwd','Michael')


三、抽取到基类中



  • 3.1、元类的创建


class ModelMetaclass(type):
      def __new__(cls, name, bases, attrs):
           mappings = dict()
           # 判断是否需要保存
           for k, v in attrs.items():
                  # 判断是否是指定的StringField或者IntegerField的实例对象
                  if isinstance(v, tuple):
                      print('Found mapping: %s ==> %s' % (k, v))
                      mappings[k] = v
           # 删除这些已经在字典中存储的属性
           for k in mappings.keys():
                attrs.pop(k)
           # 将之前的uid/name/email/password以及对应的对象引用、类名字
           attrs['__mappings__'] = mappings  # 保存属性和列的映射关系
           attrs['__table__'] = name  # 假设表名和类名一致
           return type.__new__(cls, name, bases, attrs)
  • 3.2、基类的创建


class Model(object, metaclass=ModelMetaclass):
       def __init__(self, **kwargs):
              for name, value in kwargs.items():
                    setattr(self, name, value)
       def save(self):
              fields = []
              args = []
              for k, v in self.__mappings__.items():
                    fields.append(v[0])
                    args.append(getattr(self, k, None))
             args_temp = list()
             for temp in args:
                   # 判断入如果是数字类型
                   if isinstance(temp, int):
                         args_temp.append(str(temp))
                   elif isinstance(temp, str):
                         args_temp.append("""'%s'""" % temp)
             sql = 'insert into %s (%s) values (%s)' % (self.__table__, ','.join(fields), ','.join(args_temp))
             print('SQL: %s' % sql)
  • 3.3、创建一个类对象,并保存数据


class Person(Model):
       uid = ('uid', "int unsigned")
       name = ('username', "varchar(30)")
       email = ('email', "varchar(30)")
       password = ('password', "varchar(30)")
p = Person(uid=12345, name='Michael', email='test@orm.org', password='my-pwd')
# print(p.__dict__)
p.save()
  • 4.4、上面 4.1、4.2、4.3 是连着的,在基类Model里面,我们还可以写 : 其他的 方法去实现 sql 语句的功能,上面只是写了一个插入的方法,Django框架 里面的底层就是如此实现的。只不过他们是变化了一下写法,如下:
    我们写


uid = ('uid', "int unsigned")
  • Django 写


uid = IntergerField("uid")


提示:就上面这一点区别,要理解上面代码的ORM思想

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
如何设置阿里云服务器安全组?阿里云安全组规则详细解说
阿里云安全组设置详细图文教程(收藏起来) 阿里云服务器安全组设置规则分享,阿里云服务器安全组如何放行端口设置教程。阿里云会要求客户设置安全组,如果不设置,阿里云会指定默认的安全组。那么,这个安全组是什么呢?顾名思义,就是为了服务器安全设置的。安全组其实就是一个虚拟的防火墙,可以让用户从端口、IP的维度来筛选对应服务器的访问者,从而形成一个云上的安全域。
21043 0
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,阿里云优惠总结大概有三种登录方式: 登录到ECS云服务器控制台 在ECS云服务器控制台用户可以更改密码、更换系.
30426 0
阿里云服务器安全组设置内网互通的方法
虽然0.0.0.0/0使用非常方便,但是发现很多同学使用它来做内网互通,这是有安全风险的,实例有可能会在经典网络被内网IP访问到。下面介绍一下四种安全的内网互联设置方法。 购买前请先:领取阿里云幸运券,有很多优惠,可到下文中领取。
23155 0
阿里云服务器端口号设置
阿里云服务器初级使用者可能面临的问题之一. 使用tomcat或者其他服务器软件设置端口号后,比如 一些不是默认的, mysql的 3306, mssql的1433,有时候打不开网页, 原因是没有在ecs安全组去设置这个端口号. 解决: 点击ecs下网络和安全下的安全组 在弹出的安全组中,如果没有就新建安全组,然后点击配置规则 最后如上图点击添加...或快速创建.   have fun!  将编程看作是一门艺术,而不单单是个技术。
21361 0
阿里云服务器ECS登录用户名是什么?系统不同默认账号也不同
阿里云服务器Windows系统默认用户名administrator,Linux镜像服务器用户名root
17511 0
腾讯云服务器 设置ngxin + fastdfs +tomcat 开机自启动
在tomcat中新建一个可以启动的 .sh 脚本文件 /usr/local/tomcat7/bin/ export JAVA_HOME=/usr/local/java/jdk7 export PATH=$JAVA_HOME/bin/:$PATH export CLASSPATH=.
14929 0
使用OpenApi弹性释放和设置云服务器ECS释放
云服务器ECS的一个重要特性就是按需创建资源。您可以在业务高峰期按需弹性的自定义规则进行资源创建,在完成业务计算的时候释放资源。本篇将提供几个Tips帮助您更加容易和自动化的完成云服务器的释放和弹性设置。
20943 0
+关注
433
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载