所以我正在编写迁移,它将为数据库的每条记录中的 PointField 分配纬度和经度值。
我有一个可行的解决方案,但对于 10 000 000 条记录的数据库来说太慢了。因此,我可以通过简单地将纬度和经度分配给一个点来更新 for 循环中的每个记录,然后保存记录。但我想使用 Django 的 .update() 方法来更快地完成此操作。
class Listing(AirbnbModel):
latitude = models.DecimalField()
longitude = models.DecimalField()
point = PointField(srid=4326, geography=True, null=True) # new field
这可行,但需要太多时间,而且对于 10 000 000 条记录几乎不可能做到这一点
for listing in Listing.objects.all():
listing.point = Point(float(listing.latitude), float(listing.longitude))
listing.save()
这是我尝试执行的操作,但出现错误。
Listing.objects.all().update(point=ExpressionWrapper(F('latitude'), F('longitude') , output_field=PointField()))
我也尝试过这个
Listing.objects.all().update(point=ExpressionWrapper(Point(Value('latitude'), Value('longitude')), output_field=PointField()))
但这根本不起作用。
最佳答案
我得到了答案。这是解决方案。我为此使用了 SQL
with connections[self.db_name].cursor() as cursor:
cursor.execute(
f"UPDATE listings SET point = ST_MakePoint(latitude, longitude);"
)
这个解决方案很快。
关于python - 如何使用 F 表达式在 update() 中为每个 PointField 分配纬度和经度?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55628419/