ORM字段在数据库的重要性及应用分析 (数据库的orm字段)

2023年 8月 11日 29.9k 0

ORM(Object-Relational Mapping)字段在数据库中被广泛使用,主要是用来把关系型数据库中的表结构转化成面向对象的模型,使得程序员可以像使用面向对象编程语言一样来操作数据库。ORM字段在数据库中的重要性不言而喻,对于企业的应用系统来说,ORM框架是一项必不可少的技术。

一、ORM字段的重要性

1.降低数据库操作门槛

相对于传统的数据库操作方式,ORM框架的使用可以极大地降低数据库操作的门槛,因为ORM框架提供了一套面向对象的API接口,程序员可以像操作普通对象一样来操作数据库,不再需要关注复杂的SQL语句,使得代码更加简洁易懂,易于维护。

2.提高程序员的工作效率

ORM框架的使用可以让程序员专注于业务逻辑的实现,而不需要关注底层数据库的细节,使得程序员能够更快速地开发出高质量的代码。ORM框架可以自动生成常用的CRUD操作,比如插入、更新、删除等,大大减少了程序员的工作量,提高了开发效率。

3.提高代码的可读性和可维护性

ORM框架可以将数据库中的表结构转化成面向对象的模型,让代码更加符合人类的思维模式,提高了代码的可读性。另外,ORM框架还提供了良好的抽象层,使得程序员可以轻松地更换底层数据库的实现,同时也方便了代码的维护。

二、ORM字段的应用分析

1.减少SQL注入漏洞的发生

ORM框架通过参数化的SQL语句,减少了SQL注入漏洞的发生,提高了应用系统的安全性。因为参数化的SQL语句可以保证参数的值不会被误解释为SQL代码,从而避免了SQL注入漏洞的发生。

2.数据持久化的实现

ORM框架可以很方便地将对象转化成数据库中的数据记录,实现数据的持久化。ORM框架提供了两种方式来实现数据持久化,一种是自动化的持久化,即将对象变化自动反映到数据库中,另一种是手动化的持久化,即通过手动调用保存、更新等操作来实现数据持久化。

3.提高应用系统的可扩展性

ORM框架可以提高应用系统的可扩展性,因为ORM框架提供了良好的抽象层,使得程序员可以轻松地更换底层数据库的实现。比如,如果应用系统中使用的是MySQL数据库,而后来需要更换为Oracle数据库,使用ORM框架就可以轻松地实现这一切换。

4.实现对象关系映射

ORM框架可以实现对象关系映射,即将多个对象之间的关系映射到数据库中的多个表之间的关系。ORM框架可以支持多种关系映射方式,比如一对一、一对多、多对多等,从而满足不同应用系统的需求。

5.提高应用系统的可移植性

ORM框架可以提高应用系统的可移植性,因为ORM框架可以屏蔽不同底层数据库之间的差异,使得开发人员可以使用统一的API接口来操作不同的数据库。这样,应用系统就可以轻松地在不同的操作系统、不同的数据库上运行。

综上所述,ORM字段在数据库中的重要性不可忽视。ORM框架的使用可以降低数据库操作门槛,提高程序员的工作效率,提高代码的可读性和可维护性。同时,ORM框架还可以实现数据持久化、对象关系映射、提高应用系统的可扩展性和可移植性等功能,使得应用系统更加强大和灵活。

相关问题拓展阅读:

  • 基于Pandas的数据分析平台,数据连接该不该用SqlAlchemy的ORM
  • android orm entity里属性删除了,数据库表字段会变吗

基于Pandas的数据分析平台,数据连接该不该用SqlAlchemy的ORM

一、开始使用:

from sqlalchemy import create_engine

from sqlalchemy.orm import sessionmaker

DB_CONNECT_STRING = ‘mysql+

engine = create_engine(DB_CONNECT_STRING, echo=True)

DB_Session = sessionmaker(bind=engine)

session = DB_Session()

这里的 DB_CONNECT_STRING 就是连接数据库埋吵的路径。“mysql+mysqldb”指定了使用 MySQL-Python 来连接,“root”和“123”分别是用户名和密码,“localhost”是数据库的域名,“ooxx”是使用的数据库名(可省略脊凳),“charset”指定了连接时使用的字符集(可省略)。

create_engine() 会返回一个数据库引擎,echo 参数为 True 时,会显示每条执行的 SQL 语句,生产环境下可关闭。

sessionmaker() 会樱液旅生成一个数据库会话类。这个类的实例可以当成一个数据库连接,它同时还记录了一些查询的数据,并决定什么时候执行 SQL 语句。由于 SQLAlchemy 自己维护了一个数据库连接池(默认 5 个连接),因此初始化一个会话的开销并不大。对 Tornado 而言,可以在 BaseHandler 的 initialize() 里初始化:

class BaseHandler(tornado.web.RequestHandler):

def initialize(self):

self.session = models.DB_Session()

def on_finish(self):

self.session.close()

对其他 Web 服务器来说,可以使用 sqlalchemy.orm.scoped_session,它能保证每个线程获得的 session 对象都是唯一的。不过 Tornado 本身就是单线程的,如果使用了异步方式,就可能会出现问题,因此并没使用它。

拿到 session 后,就可以执行 SQL 了:

session.execute(‘create database abc’)

print session.execute(‘show databases’).fetchall()

session.execute(‘use abc’)

# 建 user 表的过程略

print session.execute(‘select * from user where id = 1’).first()

print session.execute(‘select * from user where id = :id’, {‘id’: 1}).first()

不过这和直接使用 MySQL-Python 没啥区别;ORM 的方式,这也是采用 SQLAlchemy 的唯一原因。

于是来定义一个表:

from sqlalchemy import Column

from sqlalchemy.types import CHAR, Integer, String

from sqlalchemy.ext.declarative import declarative_base

BaseModel = declarative_base()

def init_db():

BaseModel.metadata.create_all(engine)

def drop_db():

BaseModel.metadata.drop_all(engine)

class User(BaseModel):

__tablename__ = ‘user’

id = Column(Integer, primary_key=True)

name = Column(CHAR(30)) # or Column(String(30))

init_db()

declarative_base() 创建了一个 BaseModel 类,这个类的子类可以自动与一个表关联。

以 User 类为例,它的 __tablename__ 属性就是数据库中该表的名称,它有 id 和 name 这两个字段,分别为整型和 30 个定长字符。Column 还有一些其他的参数,我就不解释了。

最后,BaseModel.metadata.create_all(engine) 会找到 BaseModel 的所有子类,并在数据库中建立这些表;drop_all() 则是删除这些表。

接着就开始使用这个表吧:

from sqlalchemy import func, or_, not_

user = User(name=’a’)

session.add(user)

user = User(name=’b’)

session.add(user)

user = User(name=’a’)

session.add(user)

user = User()

session.add(user)

session.commit()

query = session.query(User)

print query # 显示SQL 语句

print query.statement # 同上

for user in query: # 遍历时查询

print user.name

print query.all() # 返回的是一个类似列表的对象

print query.first().name # 记录不存在时,first() 会返回 None

# print query.one().name # 不存在,或有多行记录时会抛出异常

print query.filter(User.id == 2).first().name

print query.get(2).name # 以主键获取,等效于上句

print query.filter(‘id = 2’).first().name # 支持字符串

query2 = session.query(User.name)

print query2.all() # 每行是个元组

print query2.limit(1).all() # 最多返回 1 条记录

print query2.offset(1).all() # 从第 2 条记录开始返回

print query2.order_by(User.name).all()

print query2.order_by(‘name’).all()

print query2.order_by(User.name.desc()).all()

print query2.order_by(‘name desc’).all()

print session.query(User.id).order_by(User.name.desc(), User.id).all()

print query2.filter(User.id == 1).scalar() # 如果有记录,返回之一条记录的之一个元素

print session.query(‘id’).select_from(User).filter(‘id = 1’).scalar()

print query2.filter(User.id > 1, User.name != ‘a’).scalar() # and

query3 = query2.filter(User.id > 1) # 多次拼接的 filter 也是 and

query3 = query3.filter(User.name != ‘a’)

print query3.scalar()

print query2.filter(or_(User.id == 1, User.id == 2)).all() # or

print query2.filter(User.id.in_((1, 2))).all() # in

query4 = session.query(User.id)

print query4.filter(User.name == None).scalar()

print query4.filter(‘name is null’).scalar()

print query4.filter(not_(User.name == None)).all() # not

print query4.filter(User.name != None).all()

print query4.count()

print session.query(func.count(‘*’)).select_from(User).scalar()

print session.query(func.count(‘1’)).select_from(User).scalar()

print session.query(func.count(User.id)).scalar()

print session.query(func.count(‘*’)).filter(User.id > 0).scalar() # filter() 中包含 User,因此不需要指定表

print session.query(func.count(‘*’)).filter(User.name == ‘a’).limit(1).scalar() == 1 # 可以用 limit() 限制 count() 的返回数

print session.query(func.sum(User.id)).scalar()

print session.query(func.now()).scalar() # func 后可以跟任意函数名,只要该数据库支持

print session.query(func.current_timestamp()).scalar()

print session.query(func.md5(User.name)).filter(User.id == 1).scalar()

query.filter(User.id == 1).update({User.name: ‘c’})

user = query.get(1)

print user.name

user.name = ‘d’

session.flush() # 写数据库,但并不提交

print query.get(1).name

session.delete(user)

session.flush()

print query.get(1)

session.rollback()

print query.get(1).name

query.filter(User.id == 1).delete()

session.commit()

print query.get(1)

二、进阶的知识。

1)如何批量插入大批数据?

可以使用非 ORM 的方式:

session.execute(

User.__table__.insert(),

)

session.commit()

如何批量插入大批数据?

可以使用非 ORM 的方式:

session.execute(

User.__table__.insert(),

)

session.commit()

上面批量插入了条记录,半秒内就执行完了;而 ORM 方式会花掉很长时间。

2)如何让执行的 SQL 语句增加前缀?

使用 query 对象的 prefix_with() 方法:

session.query(User.name).prefix_with(‘HIGH_PRIORITY’).all()

session.execute(User.__table__.insert().prefix_with(‘IGNORE’), {‘id’: 1, ‘name’: ‘1’})

3)如何替换一个已有主键的记录?

使用 session.merge() 方法替代 session.add(),其实就是 SELECT + UPDATE:

user = User(id=1, name=’ooxx’)

session.merge(user)

session.commit()

或者使用 MySQL 的 INSERT … ON DUPLICATE KEY UPDATE,需要用到 @compiles 装饰器,有点难懂,自己看吧:《SQLAlchemy ON DUPLICATE KEY UPDATE》 和 sqlalchemy_mysql_ext。

4)如何使用无符号整数?

可以使用 MySQL 的方言:

from sqlalchemy.dialects.mysql import INTEGER

id = Column(INTEGER(unsigned=True), primary_key=True)

5)模型的属性名需要和表的字段名不一样怎么办?

开发时遇到过一个奇怪的需求,有个其他系统的表里包含了一个“from”字段,这在 Python 里是关键字,于是只能这样处理了:

from_ = Column(‘from’, CHAR(10))

6)如何获取字段的长度?

Column 会生成一个很复杂的对象,想获取长度比较麻烦,这里以 User.name 为例:

User.name.property.columns.type.length

7)如何指定使用 InnoDB,以及使用 UTF-8 编码?

最简单的方式就是修改数据库的默认配置。如果非要在代码里指定的话,可以这样:

class User(BaseModel):

__table_args__ = {

‘mysql_engine’: ‘InnoDB’,

‘mysql_charset’: ‘utf8’

}

MySQL 5.5 开始支持存储 4 字节的 UTF-8 编码的字符了,iOS 里自带的 emoji(如 ?? 字符)就属于这种。

如果是对表来设置的话,可以把上面代码中的 utf8 改成 utf8mb4,DB_CONNECT_STRING 里的 charset 也这样更改。

如果对库或字段来设置,则还是自己写 SQL 语句比较方便,具体细节可参考《How to support full Unicode in MySQL databases》。

不建议全用 utf8mb4 代替 utf8,因为前者更慢,索引会占用更多空间。

8)如何设置外键约束?

from random import randint

from sqlalchemy import ForeignKey

class User(BaseModel):

__tablename__ = ‘user’

id = Column(Integer, primary_key=True)

age = Column(Integer)

class Friendship(BaseModel):

__tablename__ = ‘friendship’

id = Column(Integer, primary_key=True)

user_id1 = Column(Integer, ForeignKey(‘user.id’))

user_id2 = Column(Integer, ForeignKey(‘user.id’))

for i in xrange(100):

session.add(User(age=randint(1, 100)))

session.flush() # 或 session.commit(),执行完后,user 对象的 id 属性才可以访问(因为 id 是自增的)

for i in xrange(100):

session.add(Friendship(user_id1=randint(1, 100), user_id2=randint(1, 100)))

session.commit()

session.query(User).filter(User.age

执行这段代码时,应该会遇到一个错误:

sqlalchemy.exc.IntegrityError: (IntegrityError) (1451, ‘Cannot delete or update a parent row: a foreign key constraint fails (`ooxx`.`friendship`, CONSTRAINT `friendship_ibfk_1` FOREIGN KEY (`user_id1`) REFERENCES `user` (`id`))’) ‘DELETE FROM user WHERE user.age

除了删除,还有可能更改主键,这也会导致 friendship 的外键失效。于是相应的就有 ON UPDATE 了。其中 CASCADE 变成了更新相应的外键,而不是删除。

而在 SQLAlchemy 中是这样处理的:

class Friendship(BaseModel):

__tablename__ = ‘friendship’

id = Column(Integer, primary_key=True)

user_id1 = Column(Integer, ForeignKey(‘user.id’, ondelete=’CASCADE’, onupdate=’CASCADE’))

user_id2 = Column(Integer, ForeignKey(‘user.id’, ondelete=’CASCADE’, onupdate=’CASCADE’))

9)如何连接表?

from sqlalchemy import distinct

from sqlalchemy.orm import aliased

Friend = aliased(User, name=’Friend’)

print session.query(User.id).join(Friendship, User.id == Friendship.user_id1).all() # 所有有朋友的用户

print session.query(distinct(User.id)).join(Friendship, User.id == Friendship.user_id1).all() # 所有有朋友的用户(去掉重复的)

print session.query(User.id).join(Friendship, User.id == Friendship.user_id1).distinct().all() # 同上

print session.query(Friendship.user_id2).join(User, User.id == Friendship.user_id1).order_by(Friendship.user_id2).distinct().all() # 所有被别人当成朋友的用户

print session.query(Friendship.user_id2).select_from(User).join(Friendship, User.id == Friendship.user_id1).order_by(Friendship.user_id2).distinct().all() # 同上,join 的方向相反,但因为不是 STRAIGHT_JOIN,所以 MySQL 可以自己选择顺序

print session.query(User.id, Friendship.user_id2).join(Friendship, User.id == Friendship.user_id1).all() # 用户及其朋友

print session.query(User.id, Friendship.user_id2).join(Friendship, User.id == Friendship.user_id1).filter(User.id

print session.query(User.id, Friend.id).join(Friendship, User.id == Friendship.user_id1).join(Friend, Friend.id == Friendship.user_id2).all() # 两次 join,由于使用到相同的表,因此需要别名

print session.query(User.id, Friendship.user_id2).outerjoin(Friendship, User.id == Friendship.user_id1).all() # 用户及其朋友(无朋友则为 None,使用左连接)

android orm entity里属性删除了,数据库表字段会变吗

如果没有进行数据库同步的还应该不会有影响的,但如果删除了对应的字段,应该会出现错误的信息的。

数据库的orm字段的介绍就聊到这里吧,感谢你花时间阅读本站内容,更多关于数据库的orm字段,ORM字段在数据库的重要性及应用分析,基于Pandas的数据分析平台,数据连接该不该用SqlAlchemy的ORM,android orm entity里属性删除了,数据库表字段会变吗的信息别忘了在本站进行查找喔。

相关文章

Oracle如何使用授予和撤销权限的语法和示例
Awesome Project: 探索 MatrixOrigin 云原生分布式数据库
下载丨66页PDF,云和恩墨技术通讯(2024年7月刊)
社区版oceanbase安装
Oracle 导出CSV工具-sqluldr2
ETL数据集成丨快速将MySQL数据迁移至Doris数据库

发布评论