rails常用数据库查询操作、方法浅析
程序员文章站
2022-04-09 14:12:31
1、获取数据
获取第一条、最后一条记录
复制代码 代码如下:
model.first
model.first(options)
model.find(:first...
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")