Method: MoSQL::Streamer#sync_object

Defined in:
lib/mosql/streamer.rb

#sync_object(ns, _id) ⇒ Object 



159
160
161
162
163
164
165
166
167
168
169
170
 
# File 'lib/mosql/streamer.rb', line 159

def sync_object(ns, _id)
  primary_sql_key = @schema.primary_sql_key_for_ns(ns)
  sqlid           = @sql.transform_one_ns(ns, { '_id' => _id })[primary_sql_key]
  obj             = collection_for_ns(ns).find_one({:_id => _id})
  if obj
    unsafe_handle_exceptions(ns, obj) do
      @sql.upsert_ns(ns, obj)
    end
  else
    @sql.table_for_ns(ns).where(primary_sql_key.to_sym => sqlid).delete()
  end
end