RethinkDB в рубине

 r

Эта строка позволяет использовать r = RQL.new Просто делает немного приятнее написание кода запроса. Если вы не хотите использовать ярлыки, вы можете создать собственную ссылку на RethinkDB:

 r.connect

Далее мы устанавливаем соединение с помощью вызова conn = r.connect(:host => "localhost", :port => 28015)

 r.db("testdb").table_create("people").run(conn)

Здесь идет фактический запрос:

 .db("testdb")

Эта строка представляет довольно важную часть DSL запроса RethinkDB. Как правило, вызовы могут быть объединены в цепочку, поскольку все они возвращают объекты RQL (если у вас есть некоторый опыт работы с Javascript, вам, вероятно, понравится эта идея). С помощью .table_create("people") .run(conn)pry Но на самом деле ничего этого не происходит, пока мы не irb

Итак, давайте предположим, что вы выполнили этот запрос и таблица была создана. Как мы можем это проверить? Мы не хотим создавать другой файл, чтобы просто перечислить таблицы в базе данных, поэтому мы будем использовать Ruby REPL ( r.connect(:host => "localhost", :port => 28015).repl.repl Сначала мы хотим установить соединение:

 r.db('testdb').table_list.run

Обратите внимание на ["people", "test_table"] Это делает так, что RQL будет предполагать, что вы будете использовать это соединение по умолчанию. Это значительно облегчает работу с REPL. Давайте проверим запрос, который даст нам список таблиц внутри «testdb»:

 require 'rethinkdb'
include RethinkDB::Shortcuts

table = "people"
db = "testdb"

begin
    conn = r.connect(:host => "localhost", :port => 28015)
rescue Exception => err
    puts "Cannot connect to RethinkDB at localhost:28015"
end

begin
    r.db(db).table_create(table).run(conn)
rescue RethinkDB::RqlRuntimeError => err
    puts "Error occurred in creating #{table} table within #{db}"
    puts err
end

begin
    puts "Tables inside #{db}: ", r.db(db).table_list().run(conn)
rescue RethinkDB::RqlRuntimeError => err
    puts err
ensure
    conn.close
end

Это должно вернуть что-то вроде:

 ensure

Хорошо круто Но ждать. В примере, который мы только что выполнили, многое отсутствует. Что, если что-то пойдет не так?

Обработка исключений

Материал работает неправильно при работе с базой данных все время. Мы всегда хотим быть уверены, что наш код может противостоять или, по крайней мере, реагировать на проблемы, возникающие при работе с RethinkDB. Давайте перепишем наш предыдущий пример немного по-другому:

 people

По сути, мы обернули все в исключения, а также добавили условие sure, чтобы мы могли закрыть соединение с RethinkDB. Вы можете думать об исключениях RethinkDB как о любом другом исключении, за исключением того, что они, как правило, действительно важны. Поэтому, если вы решите игнорировать (то есть не спасать) данное исключение, полностью понимайте его последствия.

документы

Хорошо, как мы на самом деле положить вещи в наш стол? Как вы помните, RethinkDB — это хранилище документов, а это означает, что он хранит объекты JSON. Давайте поместим человека в нашу таблицу сотрудников (я представлю форму REPL, но для ее перемещения в код просто необходимо передать объект подключения для run

 res = r.db("testdb").table("people").insert({:name => "Dhaivat"}).run

Это должно было вернуть что-то вроде:

 {"deleted"=>0, "errors"=>0, "generated_keys"=>["417b5b3e-c107-4577-acfc-cd11a76f9174"], "inserted"=>1, "replaced"=>0, "skipped"=>0, "unchanged"=>0}

Обратите внимание, что это хеш Ruby, поэтому довольно ясно, как мы получим значения из этой структуры (например, res['generated_keys'] Есть несколько важных частей структуры. Прежде всего, generated_keys Во-вторых, положительное значение для inserted Чтобы вставить несколько документов одним запросом, просто вставьте их в список и передайте их в .insert Одним из наиболее важных моментов здесь является то, что RethinkDB не должно волновать, какова структура ваших документов. В отличие от MySQL (и других RDMBS), где вы указываете структуру таблицы, RethinkDB позволяет вам просто делать это каждый раз, когда вы помещаете вещи в свою базу данных. Это означает, что либо ваш взаимодействующий с БД код должен быть очень осторожным, либо вы должны следить за тем, чтобы старые структуры не задерживались слишком долго. В качестве упражнения добавьте документы для «Джона», «Джейн» и «Джорджа».

Вставить документы довольно легко. Как насчет их возвращения снова? Мы можем получить итератор, указывающий на определенную точку в таблице. Если мы хотим перебрать все объекты в таблице:

 itr = r.db('testdb').table('people').run
itr.each do |document|
    p document
end

Что, если мы хотим фильтровать в соответствии с некоторыми ограничениями? Все, что нам нужно сделать, это создать запрос, который определяет фильтр:

 itr = r.db('testdb').table('people').filter {|person| person['name'].eq("John")}.run
itr.each do |document|
    p document
end

Здесь мы используем filter {|person| person['name'].eq("John")} .eq Обратите внимание, что мы проводим сравнение на равенство с ==r.db('testdb').table('people').
filter {|person| person['name'].eq("John")}.
delete.run По сути, любое логическое условие, которое мы можем приготовить, может использоваться как часть фильтра. Мы можем удалить документы аналогичным образом:

 id

Мы можем легко запросить на основе itr = r.db('testdb').table('people')
itr.get(id)

 itr.update({name: "Dhaivat Pandya"}).run

Обновление работает аналогично:

 itr

Какие бы документы ни повторялись с помощью "Dhaivat Pandya"

Примечание о RQL

Если вы привыкли к SQL, вам может быть интересно, в чем смысл фильтрации, если мы уже сначала откатили всю таблицу. Ну, у нас нет. Все, что предшествует .run Короче говоря, все запросы выполняются на сервере. Мой опыт работы с RQL был довольно приятным; цепочка запросов, простота фильтрации и т. д. делают использование RQL приятным.

Завершение

Эта статья должна послужить довольно быстрым введением в RethinkDB. Но есть огромное количество вещей, которые все еще остаются нетронутыми, например, объединения таблиц, уменьшение карт и т. Д. В будущих статьях мы рассмотрим все эти интересные темы.

Оставьте любые вопросы в комментариях ниже.