1

Имеются 2 разные базы данных PostgreSQL, необходимо из pn базы таблицы MdDistrict вытащить id и name и сопоставить с pd базой таблицой District, если есть совпадения добавить pn_id в мою базу ну и если нет совпадений, то добавить запись с параметрами.Доступ к базе есть, получаю массив записей

md = MdDistrict.where(type_id: 2).select(:id).select(:name)

Как это можно сделать методом

Мне необходимо обновить записи в моей базе одно поле из другой таблицы, а если записи нет, то создать новую

Логика алгоритма , я получаю массив записей своей таблицы и таблицы откуда мне нужно сравнить записи

Это записи чужой таблицы

=> [#<MdSeparation id: 638, name: "№404", c_id: 36988>, #<MdSeparation id: 242, name: "№101", c_id: 36988>, #<MdSeparation id: 1114, name: "1", c_id: 1683919>, #<MdSeparation id: 294, name: "№911", c_id: 36988>, #<MdSeparation id: 55, name: "№1", c_id: 33683>]

Это я получаю записи своей таблицы

=> [#<Organization id: 244, name: "№103", lsd_organization_id: 36988>, #<Organization id: 246, name: "№105", lsd_organization_id: 36988>, #<Organization id: 247, name: "№106", lsd_organization_id: 36988>, #<Organization id: 248, name: "№107", lsd_organization_id: 36988>]

Мне необходимо сравнить записи и обновить свою таблицу данными из таблицы Separation. Сравнить как мне подсказали я могу, но как мне из массива сделать хэш, для сравнения и как мне понять к какой записи я обращаться буду. Или сравнивать массивы записей, но как так как запись элемента массива это

<Organization id: 244, name: "№103", lsd_organization_id: 36988>

даже использование в запросе lsd_organization_id as c_id вовсе убирает значение из массива.

UPDATE

Пошел по пути поиска записи в базе и обновлении её, если совпало поле name.

def self.find_lsd_sector_org
    MdDistrict.find_by_sql("SELECT md_separation.clinic_id , md_district.id, md_district.name, md_clinic.full_name
    FROM md_district
    JOIN md_separation ON md_separation.id = md_district.separation_id
    join md_clinic on md_clinic.id = md_separation.clinic_id
    WHERE md_district.type_id = 2").each do |f|          
            sector = Sector.where("lower (name) like lower (?)", "#{f.name}")
            if sector.present?
              sector.first.update_attributes(:lsd_id, f.id)
            else
              Sector.create(lsd_id: f.id, name: f.name)
            end
          end
        end
end

Плюс необходимо сравнивать еще по организации.

Organization.select(:lsd_organization_id).each do |g|
sector = Sector.where("lower (name) like lower (?) and lower (что поставить тут) like lower (?)", "#{f.name}", "#{f.???}")

В Organization.lsd_organization_id совпадает с таблицой md_separation.id, а Sector.organization_id=Organazation.id, как сделать еще одну проверку? как я пробовал, у меня выходит что Like не работает с целыми числами.

2 ответа 2

1

Если я правильно все понял, то:

  • Нужно использовать две группы моделей - родные модели от родной БД проекта лежат как лежали, а для моделей второй БД создать подкаталог и обернуть в модули.
  • Далее в подкаталоге в файл application_record.rb добавить эту строку: establish_connection :development_second_db, где development_second_db лежит в файле config/database.yml.

Далее работаете с моделями. Например, так Post.first и SecondDb::Post.first.

Пример структуры каталогов:

  • /app/models
    • /second_db
      • application_record.rb
      • остальные модели
    • application_record.rb
    • остальные модели

Пример моделей:

class SecondDb::ApplicationRecord < ActiveRecord::Base
    establish_connection :development_second_db
    self.abstract_class = true
end

class SecondDb::Post < SecondDb::ApplicationRecord
    # ...
end
8
  • Модели есть, связи есть, я просто не совсем понимаю, как это реализовать, как массово проверить и обновить записи.
    – an0mality
    7 авг 2017 в 13:38
  • @an0mality прочитал то что вы дописали, но все равно мало что понял :) Если вы можете работать с данными обоих таблиц, то я не понимаю в чем проблема. Вы просто берете нужные вам данные из одной таблицы, далее берете нужные вам данные из второй таблицы. Делаете что вам нужно. И в конце записываете результат куда вам нужно.
    – Colibri
    7 авг 2017 в 13:41
  • возможно вы правы, но вопрос в том, что как мне например сравнить 2 хэша. Первый массив записей я получаю MdDistrict.where(type_id: 2).select("id, name") второй sector = Sector.select("lsd_id,name") как мне сравнить их, точнее если я использую lsd_id и просто id и как мне после добавить например записи, которых нет в моей но есть в другой
    – an0mality
    7 авг 2017 в 13:56
  • @an0mality если нужно иметь идентичные имена полей в выдаче, то это lsd_id AS id. Проверка, хм - это if; district.take.id == sector.take.id, но перед этим что-то типа exists? нужно использовать, или find_by.
    – Colibri
    7 авг 2017 в 14:03
  • Спасибо, завтра уже что-то попробую. сравнение хэшей хорошая идея.
    – an0mality
    7 авг 2017 в 14:15
0

Возможно я не прав, с запросами и циклами, но на данный момент работает, но хотел бы выслушать комментарии и возможно другое решение

Organization.all.each do |org|
      MdClinicSeparation.find_by_sql("SELECT md_clinic_separation.clinic_id , md_clinic_district.id, md_clinic_district.name
FROM md_clinic_separation JOIN md_clinic_district ON md_clinic_district.separation_id = md_clinic_separation.id
 WHERE md_clinic_separation.name like '%Пед%' AND md_clinic_separation.clinic_id = #{org.lsd_organization_id} AND md_clinic_district.to_dt is NULL").each do |f|
        sec = Sector.where("lower(name) like lower(?)","#{f.name.strip}")
        if sec.present?
          sec.first.update_attribute(:lsd_sector_id, f.id)
        else
          Sector.create(lsd_sector_id: f.id, name: f.name, organization_id: org.id)
        end
      end
    end
  end

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.