您的位置：首页 > 编程技术 > Ruby  >  rails常用数据库查询操作、方法浅析

rails常用数据库查询操作、方法浅析

 更新时间：2020年6月30日 23:54  点击：2668

1、获取数据

获取第一条、最后一条记录

复制代码 代码如下:

Model.first
Model.first(options)
Model.find(:first, options)
Model.last
Model.last(options)
Model.find(:last, options)

通过id获取记录

复制代码 代码如下:

Model.find(1, 10, options)
Model.find([1, 10], options)
.find all

复制代码 代码如下:

Model.all(options)

对一组数据进行相同操作

复制代码 代码如下:

User.all.each do |user|
    NewsLetter.weekly_deliver(user)
end

如果表记录数比较大，这种方式比较耗资源，因为它会一次载入整个表的数据。改用以下这种方式，它每次只载入1000行，然后逐步yield完整个表

复制代码 代码如下:

User.find_each do |user|
    NewsLetter.weekly_deliver(user)
end

自定义方式，find_each接受和find同样的options

复制代码 代码如下:

User.find_each(:batch_size => 5000, :start => 2000) do |user|
    NewsLetter.weekly_deliver(user)
end

find_in_batches，和find_each相似，但它yield时传递的是model对象数组，而不是单个model对象

复制代码 代码如下:

Invoice.find_in_batches(:include => :invoice_lines) do |invoices|
    export.add_invoices(invoices)
end

2、查询条件

通过替换？来传递条件值，可避免SQL注入

复制代码 代码如下:

Client.first(:conditions => ["orders_count = ?", params[:orders])

symbol占位条件

复制代码 代码如下:

Client.all(:conditions => ["created_at >= :start_date AND created_at <= :end_date", {:start_date => params[:start_date], :end_date => params[:end_date] }])

范围条件 in(集合)

复制代码 代码如下:

Client.all(:conditions => ["created_at IN (?)", (params[:start_date].to_date)..(params[:end_date].to_date])

生成sql

复制代码 代码如下:

SELECT * FROM users WHERE (created_at IN ('2007-12-31','2008-01-01','2008-01-02','2008-01-03','2008-01-04','2008-01-05', '2008-01-06','2008-01-07','2008-01-08'))

如果要生成日期时间，再加上.to_time
复制代码 代码如下:
params[:start_date].to_date.to_time，生成2007-12-01 00:00:00格式

有上数据库会在以上条件中报错，如Mysql会报查询语句过长的错误，此时可以改成created_at > ? AND created_at < ?的形式

Hash条件

复制代码 代码如下:

Client.all(:conditions => {:locked => true })

带范围条件

复制代码 代码如下:

Client.all(:conditons => {:created => (Time.now.midnight - 1.day)..Time.now.midnight})

生成sql

复制代码 代码如下:

SELECT * FROM clients WHERE (clients.created_at BETWEEN '2008-12-21 00:00:00' AND '2008-12-22 00:00:00')

集合条件

复制代码 代码如下:

Client.all(:conditons => {:orders_count => [1,3,5])

生成sql

复制代码 代码如下:

SELECT * FROM clients WHERE (clients.orders_count IN (1,3,5))

3、查询选项

排序

复制代码 代码如下:

#单个排序
Client.all(:order => "created_at ASC")
#多个排序
Client.all(:order => "orders_count ASC, created_at DESC")

返回指定字段

复制代码 代码如下:

Client.all(:select => "viewable_by, locked")
#使用函数
Client.all(:select => "DISTINCT(name)")

限定和偏移Limit and Offset

复制代码 代码如下:

Client.all(:limit => 5)
#生成
SELECT * FROM clients LIMIT 5
Client.all(:limit => 5, :offset => 5)
#生成
SELECT * FROM clients LIMIT 5, 5

Group分组

复制代码 代码如下:

Order.all(:group => "date(created_at)", :order => "created_at")

生成sql
复制代码 代码如下:
SELECT * FROM orders GROUP BY date(created_at)

Having
复制代码 代码如下:

Order.all(:group => "date(created_at)", :having => ["created_at > ?", 1.month.ago)

生成sql
复制代码 代码如下:
SELECT * FROM orders GROUP BY date(created_at) HAVING created_at > '2009-01-15'

只读

复制代码 代码如下:

client = Client.first(:readonly => true)
client.locked = false
client.save
#对只读对象进行保存将会触发ActiveRecord::ReadOnlyRecord异常

更新时锁定记录

乐观锁Optimistic Locking

为使用乐观锁，须在表里建一个lock_version的字段，每次更新记录时，ActiveRecord自动递增lock_version的值，

复制代码 代码如下:

c1 = Client.find(1) c2 = Client.find(1) c1.name = "Michael" c1.save c2.name = "should fail" c2.save # Raises a ActiveRecord::StaleObjectError

备注：You must ensure that your database schema defaults the lock_version column to 0.

This behavior can be turned off by setting ActiveRecord::Base.lock_optimistically = false.

指定乐观锁字段名

复制代码 代码如下:

class Client < ActiveRecord::Base set_locking_column :lock_client_column end

悲观锁Pessimistic Locking
悲观锁定由数据库直接提供

复制代码 代码如下:

Item.transaction do
    i = Item.first(:lock => true)
    i.name = 'Jones'
    i.save
end

Mysql执行返回
复制代码 代码如下:
SQL (0.2ms) BEGIN Item Load (0.3ms) SELECT * FROM `items` LIMIT 1 FOR UPDATE Item Update (0.4ms) UPDATE `items` SET `updated_at` = '2009-02-07 18:05:56', `name` = 'Jones' WHERE `id` = 1 SQL (0.8ms) COMMIT

为特定数据库加入原始的lock声明
为Mysql的锁定声明为共享模式，即锁定时仍然可读

复制代码 代码如下:
Item.transaction do  i = Item.find(1, :lock => "LOCK IN SHARE MODE")  i.increment!(:views) end

4、关联表

复制代码 代码如下:

Client.all(:joins => "LEFT OUTER JOIN address ON addresses.client_id = clients.id')

生成sql
复制代码 代码如下:
SELECT clients.* FROM clients LEFT OUTER JOIN addresses ON addresses.client_id = clients.id

使用Array、Hash、Named Associations关联表
有如下model

复制代码 代码如下:

class Category < ActiveRecord::Base
    has_many :posts
end
class Post < ActiveRecord::Base
    belongs_to :category
    has_many :comments
    has_many :tags
end
class Comments <ActiveRecord::Base
    belongs_to :post
    has_one :guest
end
class Guest < ActiveRecord::Base
    belongs_to :comment
end

复制代码 代码如下:

#关联一个关系
Category.all :joins => :posts
#关联多个关系
Post.all :joins => [:category, :comments]
#嵌套关联
Category.all :joins => {:posts => [{:comments => :guest}, :tags]}

为关联查询结果设定条件

复制代码 代码如下:

time_range = (Time.now.midnight - 1.day)..Time.now.midnight Client.all :joins => :orders, :conditions => {'orders.created_at' => time_ran
#或者
time_range = (Time.now.midnight - 1.day)..Time.now.midnight Client.all :joins => :orders, :conditions => {:orders => {:created_at => time_range}}

5、优化载入
以下代码，需要执行1 + 10次sql

复制代码 代码如下:

clients = Client.all(:limit => 10) clients.each do |client|
    puts client.address.postcode
end

优化：

复制代码 代码如下:

clients = Client.all(:include => :address, :limit => 10)
clients.each do |client|
    puts client.address.postcode
end

一次性载入post的所有分类和评论

复制代码 代码如下:

Post.all :include => [:category, :comments]

载入category为1的所有post和cooment及tag

复制代码 代码如下:

Category.find 1, :include => {:posts => [{:comments => :guest}, :tags]}

6、动态查询

复制代码 代码如下:

Client.find_by_name("Ryan")
Client.find_all_by_name("Ryan")
#！方法，没有记录时抛出ActiveRecord::RecordNotFound异常
Client.find_by_name!("Ryan")
#查询多个字段
Client.find_by_name_and_locked("Ryan", true)
#查询不到时就创建并保存
Client.find_or_create_by_name(params[:name])
#查询不到时创建一个实例，但不保存
Client.find_or_initialize_by_name('Ryan')

7、find_by_sql

复制代码 代码如下:

Client.find_by_sql("SELECT * FROM clients INNER JOIN orders ON clients.id = orders.client_id ORDER clients.created_at desc")

8、select_all
和find_by_sql类似，但不会用model实例化返回记录，你会得到一个hash数组

复制代码 代码如下:

Client.connection.select_all("SELECT * FROM clients WHERE id = '1'")

9、判断记录是否存在

复制代码 代码如下:

#通过id来查询
Client.exists?(1)
Client.exists?(1, 2, 3)
#or
Client.exists?([1,2,3])
#通过其他条件来查询
Client.exists?(:conditions => "first_name = 'Ryan'")
#没有参数时，则：表是空的 ? false : true
Client.exists?

10、计算

复制代码 代码如下:

#求结果集条数
Client.count(:conditons => "first_name = 'Ryan'")
#求某个字段非空白的条数
Client.count(:age)
#平均值
Client.average("orders_count")
#求最小值
Client.minimum("age")
#求最大值
Client.maximum("age")
#求和
Client.sum("orders_count")

[!--infotagslink--]

相关文章

  • PHP 数据库缓存Memcache操作类

    操作类就是把一些常用的一系列的数据库或相关操作写在一个类中，这样调用时我们只要调用类文件，如果要执行相关操作就直接调用类文件中的方法函数就可以实现了，下面整理了...2016-11-25

  • C#连接SQL数据库和查询数据功能的操作技巧

    本文给大家分享C#连接SQL数据库和查询数据功能的操作技巧，本文通过图文并茂的形式给大家介绍的非常详细，需要的朋友参考下吧...2021-05-17

  • Mybatis Plus select 实现只查询部分字段

    这篇文章主要介绍了Mybatis Plus select 实现只查询部分字段的操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教...2021-09-01

  • C#从数据库读取图片并保存的两种方法

    这篇文章主要介绍了C#从数据库读取图片并保存的方法，帮助大家更好的理解和使用c#，感兴趣的朋友可以了解下...2021-01-16

  • Intellij IDEA连接Navicat数据库的方法

    这篇文章主要介绍了Intellij IDEA连接Navicat数据库的方法,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借价值，需要的朋友可以参考下...2021-03-25

  • 在数据库里将毫秒转换成date格式的方法

    在开发过程中，我们经常会将日期时间的毫秒数存放到数据库，但是它对应的时间看起来就十分不方便，我们可以使用一些函数将毫秒转换成date格式。 一、 在MySQL中，有内置的函数from_unixtime()来做相应的转换，使用如下： 复制...2014-05-31

  • C#操作本地文件及保存文件到数据库的基本方法总结

    C#使用System.IO中的文件操作方法在Windows系统中处理本地文件相当顺手,这里我们还总结了在Oracle中保存文件的方法,嗯,接下来就来看看整理的C#操作本地文件及保存文件到数据库的基本方法总结...2020-06-25

  • 如何解决局域网内mysql数据库连接慢

    通过内网连另外一台机器的mysql服务， 确发现速度N慢！ 等了大约几十秒才等到提示输入密码。 但是ping mysql所在服务器却很快！ 想到很久之前有过类似的经验， telnet等一些服务在连接请求的时候，会做一些反向域名解析（如果...2015-10-21

  • MySQL快速复制数据库数据表的方法

    某些时候，例如为了搭建一个测试环境，或者克隆一个网站，需要复制一个已存在的mysql数据库。使用以下方法，可以非常简单地实现。假设已经存在的数据库名字叫db1，想要复制一份，命名为newdb。步骤如下：1. 首先创建新的数据库newd...2015-10-21

  • MyBatisPlus-QueryWrapper多条件查询及修改方式

    这篇文章主要介绍了MyBatisPlus-QueryWrapper多条件查询及修改方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教...2022-06-27

  • mysqldump命令导入导出数据库方法与实例汇总

    mysqldump命令的用法1、导出所有库系统命令行mysqldump -uusername -ppassword --all-databases > all.sql 2、导入所有库mysql命令行mysql>source all.sql; 3、导出某些库系统命令行mysqldump -uusername -ppassword...2015-10-21

  • Mysql数据库错误代码中文详细说明

    1005：创建表失败1006：创建数据库失败1007：数据库已存在，创建数据库失败1008：数据库不存在，删除数据库失败1009：不能删除数据库文件导致删除数据库失败1010：不能删除数据目录导致删除数据库失败1011：删除数据库...2013-09-23

  • Oracle使用like查询时对下划线的处理方法

    这篇文章主要介绍了Oracle使用like查询时对下划线的处理方法，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-03-16

  • 解决mybatis-plus 查询耗时慢的问题

    这篇文章主要介绍了解决mybatis-plus 查询耗时慢的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教...2021-07-04

  • c#异步读取数据库与异步更新ui的代码实现

    这篇文章主要介绍了c#从数据库里取得数据并异步更新ui的方法，大家参考使用吧...2020-06-25

  • Ruby on Rails实现最基本的用户注册和登录功能的教程

    这里我们主要以has_secure_password的用户密码验证功能为中心,来讲解Ruby on Rails实现最基本的用户注册和登录功能的教程,需要的朋友可以参考下...2020-06-30

  • Yii2.0高级框架数据库增删改查的一些操作

    yii2.0框架是PHP开发的一个比较高效率的框架，集合了作者的大量心血，下面通过用户为例给大家详解yii2使用中的一些基本的增删改查操作。 User::find()->all(); //返回所有用户数据； User::findOne($id); //返回 主键...2015-11-24

  • springBoot 项目排除数据库启动方式

    这篇文章主要介绍了springBoot 项目排除数据库启动方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教...2021-09-10

  • MYSQL数据库使用UTF-8中文编码乱码的解决办法

    1.用phpmyadmin创建数据库和数据表 创建数据库的时候，请将“整理”设置为：“utf8_general_ci” 或执行语句： 复制代码 代码如下:CREATE DATABASE `dbname` DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci; 创...2015-10-21

  • Linux 下使用shell脚本定时维护数据库的案例

    这篇文章主要介绍了Linux 下使用shell脚本定时维护数据库，本文通过案例分析给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2020-07-11