微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

更新雪花表

如何解决更新雪花表

我正在尝试通过数据块更新雪花表。我在其中创建了 databricks 临时表并基于临时表创建了查询,该查询将更新雪花表。但我不确定是否有可能有人可以帮助我。

$sql = "
    SELECT * FROM reservations
    WHERE guest_id IN (SELECT id
        FROM guests
        WHERE fname  = ?
            OR lname = ?
            OR phone = ?
            OR email = ?
    );
";

$query  = $con->prepare($sql);
$query->bind_param("ssss",$fname,$lname,$phone,$email);
$query->execute();
$result = $query->get_result();

while ($row = $result->fetch_assoc()) {
    echo $row["guest_id"],PHP_EOL; // Example output printing the guest_id of guests with reservations (followed by a newline)
}

解决方法

退后一步,考虑一下系统。

'Databricks 集群' '雪花集群'

您希望避免两个系统之间的过多通信,因为网络速度很慢。 所以我会推荐:

  1. 将您的数据复制/插入到雪花中并在那里转换合并
  2. 准备databricks中的数据,将结果复制到snowflake合并那里

所以你能不能在一个语句中从 databricks 表合并到一个 Snowflake 表,我不知道。你该不该做。可能不会。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。