标签: bulkupdate

我正在尝试使用Entity Framework批量更新记录.我试过Entity Framework.Extensions Update方法.

该Update方法能够使用相同的更新值集批量更新一组记录.

例:

           Id -  Quantity
Record 1 - A  -  10
Record 2 - B  -  20
Record 3 - C  -  30

我们可以通过简单的调用批量更新所有上述记录

Records.Update(new => Record { Quantity = 100 });

如何使用Entityframework.Extensions或以任何其他方法批量更新具有不同数量的每条记录,从而更快地完成批量更新？

我有一个Table Valued Constructor通过它选择周围的1 million记录.它将用于update另一个表.

SELECT *
FROM   (VALUES (100,200,300),
               (100,200,300),
               (100,200,300),
               (100,200,300),
               .....
               ..... --1 million records
               (100,200,300)) tc (proj_d, period_sid, val) 

这是我的原始查询:https://www.dropbox.com/s/ezomt80hsh36gws/TVC.txt？dl = 0#

当我执行上述操作时,select它只是显示查询已完成但出现错误并显示任何错误消息.

更新:尝试使用TRY/CATCH块捕获错误消息或错误号但不使用与先前映像相同的错误

BEGIN try
    SELECT *
    FROM   (VALUES (100,200,300),
                    (100,200,300),
                    (100,200,300),
                    (100,200,300),
                    .....
                    ..... --1 million records
                    (100,200,300)) tc (proj_d, period_sid, val) 
END try

BEGIN catch
    SELECT Error_number(),
           Error_message()
END catch 

为什么它没有执行是否有表Valed构造函数的限制Select.我知道Insert它是1000,但我选择在这里.

我有一个相同集合的对象/域列表，如果 Mongodb 数据库中不存在，则应将其插入，否则应按 更新现有记录过滤器_id。

虽然这可以使用 Spring data MongoRepositories 来完成，但它似乎是：

1. 太慢了！！！（可能是一条一条保存记录！！！这个操作是Bulk执行的吗？？？）
2. 如果有的话DuplicateKeyException，它会终止执行（不保存下一条记录，尽管我想忽略此类异常）

现在，如果我使用BulkOperations bulkOps = mongoTemplate.bulkOps(BulkMode.UNORDERED, collectionName)，如果完整性破坏，它仍然会抛出相同的异常！尽管根据 Spring 文档，使用BulkMode.UNORDERED：

并行执行批量操作。出现错误时，处理将继续。

考虑下面的代码：

BulkOperations bulkOps = mongoTemplate.bulkOps(BulkMode.UNORDERED, className);

        for (T entry : entries) {
            DBObject dbDoc = new BasicDBObject();
            mongoTemplate.getConverter().write(entry, dbDoc);
            Update update = Update.fromDBObject(dbDoc);
            bulkOps.updateOne(new Query(Criteria.where("_id").is(dbDoc.get("_id"))), update);
        }
        BulkWriteResult result = bulkOps.execute();

当我执行上面的代码时，出现以下异常：

java.lang.IllegalArgumentException: Invalid BSON field name _class
at org.bson.AbstractBsonWriter.writeName(AbstractBsonWriter.java:516)
at com.mongodb.DBObjectCodec.encode(DBObjectCodec.java:129)
at com.mongodb.DBObjectCodec.encode(DBObjectCodec.java:61)
at org.bson.codecs.BsonDocumentWrapperCodec.encode(BsonDocumentWrapperCodec.java:63)
at org.bson.codecs.BsonDocumentWrapperCodec.encode(BsonDocumentWrapperCodec.java:29)
at com.mongodb.connection.UpdateCommandMessage.writeTheWrites(UpdateCommandMessage.java:85)
at com.mongodb.connection.UpdateCommandMessage.writeTheWrites(UpdateCommandMessage.java:43)
at …

我试图在PostgreSQL中实现一些非常简单的Rails方式.

假设你有一个User3列模型id,cached_segment,cached_step.假设您已经有一个复杂的查询,它可以计算segment并动态地query封装在一个范围内User.decorate_with_segment_and_step.这将返回一个ActiveRecord关系,User与之相同,但增加了3个列:

id  cached_segment cached_step segment    step    cache_invalid
1   NULL           NULL        segment_1  step_1  TRUE
2   segment_1      step_2      segment_1  step_2  FALSE
3   ...

我想生成的SQL是以下(PostgreSQL风格):

UPDATE users
SET cached_segment = segment_1
    cached_step    = step
FROM (#{User.decorate_with_segment_and_step.to_sql}) decorated_users
WHERE decorated_users.cache_invalid AND decorated_users.id = users.id

理想情况下,我可以做类似的事情

User.
  from(User.decorate_with_segment_and_step, 'decorated_users').
  where(cache_invalid: true).
  update_all('cached_segment = segment, cached_step = step')

我对上面的语句没有好运update_all,根据源代码,只是from在构建update语句时丢弃该子句.

注意:我知道我可以使用User.connection.execute(my_raw_sql_here),这就是我现在正在做的事情.目标是坚持使用ActiveRecord.

对于以下命令， wherequery只能匹配一个文档（请注意，bulkWrite()默认情况下是有序的）：

final BulkWriteResult res = db.getCollection("mycol").bulkWrite(Arrays.asList(
    new UpdateOneModel<>(query,
        new Document("$addToSet", new Document("some_things", things))),
    new UpdateOneModel<>(query,
        new Document("$pull", new Document("some_things", otherthings)))));

...我知道如果第一次更新成功而第二次失败（在正常情况下应该是不可能的），第一次更新仍将应用于文档，这意味着批量写入不是严格原子的。但是，假设两个查询都成功，操作是原子的吗？例如，其他写入是否可以在两个操作之间交错？

如何通过 typeorm 中的原始查询进行批量更新？
例如，我们有一个带有属性名称的模型User 如何在一次事务中更改少数用户的名称？