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

复制代码代码如下:
Model.all(options)

对一组数据进行相同操作

复制代码代码如下:
User.all.eachdo|user|
   NewsLetter.weekly_deliver(user)
end
如果表记录数比较大，这种方式比较耗资源，因为它会一次载入整个表的数据。改用以下这种方式，它每次只载入1000行，然后逐步yield完整个表

复制代码代码如下:
User.find_eachdo|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_dateANDcreated_at<=:end_date",{:start_date=>params[:start_date],:end_date=>params[:end_date]}])
范围条件in(集合)

复制代码代码如下:
Client.all(:conditions=>["created_atIN(?)",(params[:start_date].to_date)..(params[:end_date].to_date])
生成sql

复制代码代码如下:
SELECT*FROMusersWHERE(created_atIN("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-0100:00:00格式

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

Hash条件

复制代码代码如下:
Client.all(:conditions=>{:locked=>true})
带范围条件

复制代码代码如下:
Client.all(:conditons=>{:created=>(Time.now.midnight-1.day)..Time.now.midnight})
生成sql

复制代码代码如下:
SELECT*FROMclientsWHERE(clients.created_atBETWEEN"2008-12-2100:00:00"AND"2008-12-2200:00:00")
集合条件

复制代码代码如下:
Client.all(:conditons=>{:orders_count=>[1,3,5])
生成sql

复制代码代码如下:
SELECT*FROMclientsWHERE(clients.orders_countIN(1,3,5))

3、查询选项

排序

复制代码代码如下:
#单个排序
Client.all(:order=>"created_atASC")
#多个排序
Client.all(:order=>"orders_countASC,created_atDESC")
返回指定字段

复制代码代码如下:
Client.all(:select=>"viewable_by,locked")
#使用函数
Client.all(:select=>"DISTINCT(name)")
限定和偏移LimitandOffset

复制代码代码如下:
Client.all(:limit=>5)
#生成
SELECT*FROMclientsLIMIT5
Client.all(:limit=>5,:offset=>5)
#生成
SELECT*FROMclientsLIMIT5,5
Group分组

复制代码代码如下:
Order.all(:group=>"date(created_at)",:order=>"created_at")
生成sql
复制代码代码如下:SELECT*FROMordersGROUPBYdate(created_at)
Having
复制代码代码如下:
Order.all(:group=>"date(created_at)",:having=>["created_at>?",1.month.ago)
生成sql
复制代码代码如下:SELECT*FROMordersGROUPBYdate(created_at)HAVINGcreated_at>"2009-01-15"
只读

复制代码代码如下:
client=Client.first(:readonly=>true)
client.locked=false
client.save
#对只读对象进行保存将会触发ActiveRecord::ReadOnlyRecord异常
更新时锁定记录

乐观锁OptimisticLocking

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

复制代码代码如下:
c1=Client.find(1)c2=Client.find(1)c1.name="Michael"c1.savec2.name="shouldfail"c2.save#RaisesaActiveRecord::StaleObjectError
备注：Youmustensurethatyourdatabaseschemadefaultsthelock_versioncolumnto0.

ThisbehaviorcanbeturnedoffbysettingActiveRecord::Base.lock_optimistically=false.

指定乐观锁字段名

复制代码代码如下:
classClient<ActiveRecord::Baseset_locking_column:lock_client_columnend
悲观锁PessimisticLocking
悲观锁定由数据库直接提供

复制代码代码如下:
Item.transactiondo
   i=Item.first(:lock=>true)
   i.name="Jones"
   i.save
end
Mysql执行返回
复制代码代码如下:SQL(0.2ms)BEGINItemLoad(0.3ms)SELECT*FROM`items`LIMIT1FORUPDATEItemUpdate(0.4ms)UPDATE`items`SET`updated_at`="2009-02-0718:05:56",`name`="Jones"WHERE`id`=1SQL(0.8ms)COMMIT

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

复制代码代码如下:Item.transactiondo i=Item.find(1,:lock=>"LOCKINSHAREMODE") i.increment!(:views)end

4、关联表

复制代码代码如下:
Client.all(:joins=>"LEFTOUTERJOINaddressONaddresses.client_id=clients.id")
生成sql
复制代码代码如下:SELECTclients.*FROMclientsLEFTOUTERJOINaddressesONaddresses.client_id=clients.id
使用Array、Hash、NamedAssociations关联表
有如下model

复制代码代码如下:
classCategory<ActiveRecord::Base
   has_many:posts
end
classPost<ActiveRecord::Base
   belongs_to:category
   has_many:comments
   has_many:tags
end
classComments<ActiveRecord::Base
   belongs_to:post
   has_one:guest
end
classGuest<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.midnightClient.all:joins=>:orders,:conditions=>{"orders.created_at"=>time_ran
#或者
time_range=(Time.now.midnight-1.day)..Time.now.midnightClient.all:joins=>:orders,:conditions=>{:orders=>{:created_at=>time_range}}
5、优化载入
以下代码，需要执行1+10次sql

复制代码代码如下:
clients=Client.all(:limit=>10)clients.eachdo|client|
   putsclient.address.postcode
end
优化：

复制代码代码如下:
clients=Client.all(:include=>:address,:limit=>10)
clients.eachdo|client|
   putsclient.address.postcode
end
一次性载入post的所有分类和评论

复制代码代码如下:
Post.all:include=>[:category,:comments]
载入category为1的所有post和cooment及tag

复制代码代码如下:
Category.find1,: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*FROMclientsINNERJOINordersONclients.id=orders.client_idORDERclients.created_atdesc")
8、select_all
和find_by_sql类似，但不会用model实例化返回记录，你会得到一个hash数组

复制代码代码如下:
Client.connection.select_all("SELECT*FROMclientsWHEREid="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")

本文地址： rails常用数据库查询操作、方法浅析

相关文章

• 一文汇总全密态数据库的基本使用方法
• SQLSERVER简单创建DBLINK操作远程服务器数据库的方法
• SQL Server跨服务器操作数据库的图文方法(LinkedServer)
• Oracle数据库分页的集中方法(三种方法)
• 简易指南：关闭Oracle数据库的正确方法（关闭oracle数据库命令）
• PDO MySQL类：实现数据库操作的简单方法（pdomysql类）
• Oracle数据库提取时间日期的方法（oracle取时间日期）
• Oracle 快速建立数据库的方法（oracle创建库名）
• Oracle数据库中使用拼接符号的方法（oracle中的拼接符）
• Oracle 数据库操作方法精要（oracle方法）
• 关于ASP操作Access数据库时出现死锁.ldb的解决方法
• 通过C语言操作SQL Server数据库的方法（c操作sqlserver）
• Oracle数据库操作：更新行数的方法（oracle更新行数）
• 关于ASP操作Access数据库时出现死锁.ldb的解决方法
• Oracle数据库同步写操作的实现及优化方法（oracle数据库同步写）
• C语言操作MySQL数据库的方法（c 中访问mysql）
• C程序操作MySQL数据库的锁表实现方法（c# mysql 锁表）
• 库Bat批处理查询MySQL数据库的实现方法（bat查询mysql数据）
• 精通cxoracle操作，拥抱数据库变化（cx_oracle方法）
• Oracle数据库中人民币显示实现方法（oracle 人民币显示）
• MySQL 数据库无法打开问题的解决方法（mysql不能打开数据库）
• MySQL无法创建导致数据库操作异常的解决方法（mysql不能创建）
• 用ADODB来让PHP操作ACCESS数据库的方法
• 网上提供的最简便的MySql数据库备份的方法
• 用C#对ADO.NET数据库完成简单操作的方法
• DBCCSHRINKDATABASEMSSQL数据库日志压缩方法
• 用sql语句实现分离和附加数据库的方法
• sqlserver还原数据库时提示数据库正在使用，无法进行操作的解决方法