0

问题:如何将 GraphQL 查询保存到我的本地/postgres 数据库?

(假设我只想保存一两个字段——我会做更多,但我只是不知道如何开始。)

背景:

  • 我有一个嵌入式 shopify 应用程序,它与 webhook 一起使用来消费订单。我运行一项工作,数据完美地存储在我的数据库中。

  • 我已经设置了一个超级简单的应用程序,可以在模型中进行 graphql 查询。我已经设置好了,所以我可以在视图中看到 json 对象。但我不是 100% 清楚我如何从 graphql api 查询 -> 响应(在模型中 - 至少现在) -> 将数据属性保存到我的数据库

  • 我正在将此作为新应用程序进行测试。所以,我没有拆分模型/控制器等,暂时只使用一个模型

  • 我想我只是有点失落。我需要经营一份工作吗?或者这是我可以在控制器(或模型)中做的事情。

模型

商店.rb

class Shop < ActiveRecord::Base
  include ShopifyApp::ShopSessionStorage
  has_many :orders

  def api_version
    ShopifyApp.configuration.api_version
  end

  session = ShopifyAPI::Session.new(domain: "bryanbeshore.myshopify.com", token: Shop.first.shopify_token, api_version: "2020-04")
  ShopifyAPI::Base.activate_session(session)

  client = ShopifyAPI::GraphQL.client

  SHOP_NAME_QUERY = client.parse <<-'GRAPHQL'
      {
    shop {
      name
    }
    orders(first: 100) {
      edges {
        node {
          id
          name
          createdAt
          shippingAddress {
            address1
            address2
            city
            province
            provinceCode
            zip
          }
        }
      }
    }
    }
  GRAPHQL
end

控制器

home_controller.rb

class HomeController < AuthenticatedController

  def index
    client = ShopifyAPI::GraphQL.client
    @shop_orders = client.query(Shop::SHOP_NAME_QUERY).data.to_json
  end
end

看法

应用程序/views/home/index.html.erb

<p><%= @shop_orders %></p>

当前架构

ActiveRecord::Schema.define(version: 2020_05_06_181457) do

  create_table "orders", force: :cascade do |t|
    t.string "shopify_order_id", null: false
    t.string "shopify_order_name", default: ""
    t.datetime "shopify_order_created_at"
    t.integer "shop_id"
    t.datetime "created_at", precision: 6, null: false
    t.datetime "updated_at", precision: 6, null: false
    t.index ["shop_id"], name: "index_orders_on_shop_id"
    t.index ["shopify_order_id"], name: "index_orders_on_shopify_order_id", unique: true
  end

  create_table "shops", force: :cascade do |t|
    t.string "shopify_domain", null: false
    t.string "shopify_token", null: false
    t.datetime "created_at", precision: 6, null: false
    t.datetime "updated_at", precision: 6, null: false
    t.index ["shopify_domain"], name: "index_shops_on_shopify_domain", unique: true
  end

end

4

1 回答 1

1

您正在查询Shop订单,所以我会创建一个Order模型/orders表,确保它属于一家商店。

  • rails g model Order payload:jsonb shop:references,对于这个例子,我只是创建一个jsonb字段,我们将把整个 JSON 对象转储到其中。
  • rails db:migrate
  • 加入belongs_to :shop_models/order.rb
  • 确保Shop模型有这个has_many :orders,通常rails会为你添加它

现在,当您从 Shopify 获取 JSON 有效负载时,循环遍历它并为您收到的每个订单创建一条新记录。

所以在你用来查询订单的方法中添加这个。

shopify_json_response.each do |item|
  orders.create(payload: item)
end

或多或少,这应该可以解决问题。您不需要后台作业,但是当您想要处理不需要立即处理的数据时,后台作业是理想的。

于 2020-05-20T00:10:28.563 回答