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

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")

(0)

相关推荐

  • 在Ruby程序中连接数据库的详细教程

    本章节将向您讲解如何使用 Ruby 访问数据库.Ruby DBI 模块为 Ruby 脚本提供了类似于 Perl DBI 模块的独立于数据库的接口. DBI 即 Database independent interface,代表了 Ruby 独立于数据库的接口.DBI 在 Ruby 代码与底层数据库之间提供了一个抽象层,允许您简单地实现数据库切换.它定义了一系列方法.变量和规范,提供了一个独立于数据库的一致的数据库接口. DBI 可与下列进行交互: ADO (ActiveX Data Object

  • ruby+nokogori抓取糗事百科前10页并存储进数据库示例

    ruby,nokogori,爬取糗事百科最新的10页加图片比并同时保存进文本跟数据库 复制代码 代码如下: #encoding:utf-8require "open-uri"require "nokogiri"require "mysql"@dbh=Mysql.real_connect("localhost","root","dengli","pachong")@fi

  • 浅谈Ruby on Rails下的rake与数据库数据迁移操作

    不知道你有没有把数据迁移写入Migration文件的经历,相信无论是老鸟还是新手都这样干过吧.事实上,这样做并不是行不通,只不过这样的实践慢慢会给你引入一些不必要的麻烦. 一般认为db/migrate文件夹里的内容是关于你数据库Schema的演变过程,每个新的开发或线上环境都要通过这些Migration来构建可用的数据库.但如果这里装入了,负责细节的业务代码,比如一些历史遗留数据的迁移代码之类的,当一段时间后,数据库的结构变化了,但Migration没有跟着变化,渐渐的曾经的辅助代码,就成了垃圾

  • Ruby连接使用windows下sql server数据库代码实例

    require 'win32ole' class SqlServer # This class manages database connection and queries attr_accessor :connection, :data, :fields def initialize @connection = nil @data = nil end def open # Open ADO connection to the SQL Server database connection_st

  • Ruby中访问SQL Server数据库的配置实例

    因为工作需要,要分析存放在SQL Server上的数据,所以不得不研究一下如何使用Ruby访问SQL Server,发现其实还是很简单的: 安装FreeTDS 下载FreeTDS源代码 解压编译安装: 复制代码 代码如下: ./configure --prefix=/usr/local/freetds && make && sudo make install 安装Tiny_TDS Tiny_TDS,安装和使用非常简单,推荐使用: 复制代码 代码如下: sudo gem in

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

    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 复制代码 代码如下: Mod

  • Django视图之ORM数据库查询操作API的实例

    查询表记录 查询相关API 操作:models.表名.objects.方法() <BR>all(): 查询所有结果 filter(**kwargs): 它包含了与所给筛选条件相匹配的对象 get(**kwargs): 返回与所给筛选条件相匹配的对象,返回结果有且只有一个, 如果符合筛选条件的对象超过一个或者没有都会抛出错误. exclude(**kwargs): 它包含了与所给筛选条件不匹配的对象 values(*field): 返回一个ValueQuerySet--一个特殊的QuerySet

  • tp5(thinkPHP5)框架实现多数据库查询的方法

    本文实例讲述了tp5(thinkPHP5)框架实现多数据库查询的方法.分享给大家供大家参考,具体如下: 引言: 有时候一个管理后台,需要涉及到多个数据库.比如,商城管理.直播管理.消息管理等等,它们都有自己的数据库.这个时候,就需要去连接多个数据库,进行处理了.thinkphp可以支持多个数据库连接. 如何处理呢? 1.进行多个数据库的配置 默认会连接database.php中的数据库信息. <?php // +------------------------------------------

  • php+mysqli使用预处理技术进行数据库查询的方法

    本文实例讲述了php+mysqli使用预处理技术进行数据库查询的方法.分享给大家供大家参考.具体如下: 代码有些难度,需要基础知识比较扎实才能好理解,代码先放上来: 这里实现查询所有 id>5 的 id,title,contents值: 复制代码 代码如下: <?php $mysqli = new MySQLi("localhost","root","123456","liuyan"); if(!$mysqli){

  • Django中常用的查询数据方法及查询对象的条件详解

    (1)常用的查询方法: 1.获取所有记录: s = User.objects.all() 2.获取第一条数据: s = User.objects.first() 3.获取最后一条数据: s = User.objects.last() 关于二.三两个方法注意点: 对于QuerySet对象,我们也是可以通过下标取值获取对应的实例对象.如下所示--虽然这两个方法作用一致(获取到对应的实例对象),但是推荐使用(而且一般使用的)都是first()方法及last()方法. 原因--如果查询的数据不存在的话,

  • ASP.NET 6种常用数据库的连接方法

    1.C#连接连接Access 程序代码:     复制代码 代码如下: using   System.Data; using   System.Data.OleDb;    .. string   strConnection="Provider=Microsoft.Jet.OleDb.4.0;";     strConnection+=@"Data   Source=C:BegASPNETNorthwind.mdb"; OleDbConnection   objCo

  • Mybatis使用JSONObject接收数据库查询的方法

    1. mapper.xml设置resultType resultType="com.alibaba.fastjson.JSONObject" 2. Mapper.java使用JSONObject接收 // 查询isvalid=1的数据 JSONObject selectValidBom(String parentsCode); 3. 测试 // 测试查询BOM的sql语句 @Test() public void testSelectValidBom() { JSONObject val

  • 在Django的视图中使用数据库查询的方法

    在视图中也有笨方法可以从数据库中获取数据. 很简单: 用现有的任何 Python 类库执行一条 SQL 查询并对结果进行一些处理. 在本例的视图中,我们使用了 MySQLdb 类库(可以从 http://www.djangoproject.com/r/python-mysql/ 获得)来连接 MySQL 数据库,取回一些记录,将它们提供给模板以显示一个网页: from django.shortcuts import render_to_response import MySQLdb def bo

  • python执行数据库的查询操作实例讲解

    1.fetchone该方法获取下一个查询结果集.结果集是一个对象. 2.fetchall接收全部的返回结果行. 3.rowcount这是一个只读属性,并返回执行execute方法后影响的行数. 实例 from pymysql import * def main(): # 创建Connection连接 conn = connect(host='localhost',port=3306,user='root',password='mysql',database='jing_dong',charset

  • 数据库表的查询操作实践演练(实验三)

    继前两次的实验,本次实验以熟练掌握利用select语句进行各种查询操作:单表查询.多表连接及查询.嵌套查询.集合查询等,巩固数据库查询操作. 下面就跟着小编一起练习吧! 在实验一创建并插入数据的表(Student, Course,SC,Teacher,TC)的基础上,完成以下操作. (1)将教师'罗莉'的名字改为'罗莉莉'. 复制代码 代码如下: update Teacher set tname='罗莉莉' where tname='罗莉' (2)将两个同学(数据自己临时设置,用后即删除)的两门

随机推荐