匹配时插入雪花，或未匹配时更新雪花
是指在数据库中进行数据操作的一种方式。具体来说，雪花是一个代表某个实体的数据记录，匹配是指根据某个条件在数据库中查找是否存在符合条件的雪花记录。
当进行匹配时，如果数据库中存在符合条件的雪花记录，则可以选择插入新的雪花记录，以表示匹配成功。这样可以保留原有的匹配记录，并在数据库中新增一条新的雪花记录。
而当进行匹配时，如果数据库中不存在符合条件的雪花记录，则可以选择更新已有的雪花记录，以表示未匹配成功。这样可以更新已有的雪花记录的相关信息，以反映未匹配成功的情况。
这种方式的应用场景较为广泛，特别是在需要对数据库中的数据进行实时匹配和更新的场景中。例如，在电商平台中，当用户进行商品搜索时，可以使用这种方式来匹配用户输入的关键词与数据库中的商品信息，如果匹配成功，则插入一条新的搜索记录；如果未匹配成功，则更新已有的搜索记录，以记录用户的搜索情况。
对于腾讯云的相关产品和产品介绍链接地址，以下是一些推荐的选择：
- 云数据库 TencentDB：腾讯云提供的高性能、可扩展的云数据库服务，支持多种数据库引擎，包括MySQL、SQL Server、MongoDB等。详情请参考：https://cloud.tencent.com/product/cdb
- 云服务器 CVM：腾讯云提供的弹性计算服务，可快速创建和管理云服务器实例，支持多种操作系统和应用场景。详情请参考：https://cloud.tencent.com/product/cvm
- 人工智能平台 AI Lab：腾讯云提供的人工智能开发平台，集成了多种人工智能技术和工具，包括图像识别、语音识别、自然语言处理等。详情请参考：https://cloud.tencent.com/product/ailab
请注意，以上推荐的产品和链接仅供参考，具体选择应根据实际需求和情况进行。
相关·内容
我想用Talend把数据加载到雪花中。我使用tSnowflakeOutput和Upsert选项，因为如果雪花中不存在数据，我希望插入数据，如果存在，则更新行。我使用主键来标识已经存在的行。
当我运行我的工作时，我有以下错误：
在DML操作期间检测到重复行
我知道这个问题是由于雪花中存在的一个行造成的，我想要更新这个行，但是我所得到的只是这个错误。你知道为什么吗？
(请帮助:)
浏览 4提问于2020-01-10得票数 1
我有一个具有5列的pyspark，我需要写到雪花表中有6列，5列与dataframe列相同，但是雪花表中有1条额外的自动增量列。
当我试图将此数据写入雪花表时，它会给出一个错误；由于dataframe和雪花表中有不同的列数而导致列不匹配。我已经试过了模式=‘追加’，但那不起作用。
df.write.format(snowflake_source_name) \
.options(**sfoptions) \
.option("dbtable", table_name) \
.mode("append
浏览 5提问于2019-10-10得票数 1
1回答
以前，我曾尝试使用“复制到”命令将数据加载到雪花中。现在我尝试逐行插入数据，但在执行insert查询时面临问题。
insert into SUPERHERO values('Spider-Man (Peter Parker)', 'Secret Identity', 'Good Characters', 'Hazel Eyes', 'Brown Hair', 'Male', 'Living', 4043.0, 'Aug-62', 1962.0);
insert查询在雪
浏览 4提问于2022-10-29得票数 0
回答已采纳
1回答
雪花是否支持用UPDATE *或INSERT *这样的语法更新/插入所有列？
MERGE INTO events
USING updates
ON events.eventId = updates.eventId
WHEN MATCHED THEN
UPDATE *
WHEN NOT MATCHED THEN
INSERT *
类似于Databricks是如何做到的：
还是我们必须列出每一列及其价值？
当我尝试上面的内容时，我会得到错误。
语法错误..。意想不到的“*”。
而且医生帮不了什么忙：
谢谢,
浏览 1提问于2021-05-28得票数 6
回答已采纳
我有一个场景，我必须在雪花表上运行并行插入/删除。例如:该表包含与不同国家相关的数据。且每个插入管道或线程将仅包含特定国家的数据。类似地，当我运行并行删除时，每个删除线程将只删除特定国家的数据。我希望根据国家对雪花表中的数据进行分区，这可能有助于避免任何锁。然而，在snowflake中似乎没有这种选择。
你能建议我如何实现并行插入/删除和避免争用或锁定吗？
注意:我正在使用matillion并行运行不同的ELT作业来执行插入。
浏览 2提问于2021-01-25得票数 0
试图访问雪花的市场(试图访问雪花提供了同样的错误信息)。当我登录到遗留浏览器UI并单击“”时，它会再次带我到登录屏幕。当我输入我的凭证时，它给了我一个错误：User's configured default role '<username>' does not exist or not authorized. Contact your local system administrator, or attempt to login using a CLI client with a connect string selecting another role,
浏览 3提问于2022-05-12得票数 0
回答已采纳
2回答
我以以下格式在雪花字段中接收文本数据：
电话号码99999999999标记为: XXXXXXXXX
电话号码99999999999是: XXXXXXXXX。
也就是说，“是”和“by”之间的词可以是标记的，也可以是不加标记的。
如何提取“是”和“by”之间的单词？
浏览 9提问于2022-06-10得票数 -2
回答已采纳
1回答
我对雪花有点陌生，并试图在现有的表中添加两列。
下面是这两列
创作时间
最后更新时间
有人能帮我把这件事搬到现有的雪花桌上吗？
提前谢谢。
浏览 3提问于2021-10-24得票数 1
2回答
在我的用例中，我的计划工作读取CSV并写入雪花。
当我计划这个从CSV读，并写到雪花每小时，我看到多个副本在雪花。尽管我的ID是主键( (column1) )，但这仍然存在。
据我所知，雪花支持定义和维护约束，但不强制它们，除非非空约束，这些约束总是被强制执行的。我需要帮助来解决这个问题.
为了详细说明，让我们考虑一下场景：
步骤1:上午9点将数据从CSV插入到雪花
步骤2:在晚上10点，我得到了另外一行，因此我的CSV是
预计在雪花
我得到的是如下所示的
浏览 3提问于2020-04-24得票数 0
2回答
我试图使用aws lambda (雪花连接器库)读取雪花流数据，并将数据写入RDS SQL server。在运行lambda之后，我的流数据不会被删除。
我不希望读取流中的数据，并将其插入临时雪花表中，并再次读取以插入SQL服务器中的数据。有什么更好的方法吗？
Lambda代码：
for table in table_list:
sql5 = f"""SELECT "header__stream_position","header__timestamp" FROM STREAM_{table} where "hea
浏览 3提问于2022-04-12得票数 0
回答已采纳
前任：
资料来源：S3
计划更新：2次/天
目标：雪花桌
流：否
在第0天，我在雪花数据库中创建并加载了一个customer表。S3文件每天更新2次，它们也需要在雪花表中反映出来。
我想想出一个解决方案，这样就可以在没有流媒体或消息技术的情况下，每天处理2次以下3例病例。
插入-新记录更新-现有记录删除-现有记录
浏览 0提问于2020-05-25得票数 0
我正在尝试创建一个执行合并语句的雪花任务。
然而，似乎雪花不识别“当目标不匹配”或“当不匹配源”语句。
create or replace task MERGE_TEAM_TOUCHPOINT
warehouse = COMPUTE_WH
schedule = '1 minute'
when system$stream_has_data('TEAMTOUCHPOINT_CDC')
as
merge into dv.Team_Touchpoint as f using TeamTouchpoint_CDC as s
on s.uniqueid = f
浏览 4提问于2021-03-05得票数 5
回答已采纳
我已经编写了aws glue job，我试图将雪花表作为spark数据帧读取，并尝试将spark数据帧写入snowflake表。在这两种情况下，我的工作都无法显示“操作模式的权限不足”。
但是当我在雪花cli上直接写insert语句时，我能够插入数据。所以基本上我有插入权限。
那么，当我尝试从dataframe中插入数据或从snowflake表中读取数据作为dataframe时，我的作业为什么会失败呢？
下面是我将数据写入雪花表的代码。
sfOptions = {
"sfURL" : "xt30972.snowflakecomputing.com",
浏览 0提问于2019-02-09得票数 0
我是snowflake的新手。目前使用雪花节点js sdk向雪花表中插入数据。谁能建议一下在使用雪花节点js时，如何在批量插入中使用array_construct()函数？
浏览 13提问于2020-04-24得票数 0
我想上传csv文件从谷歌工作表到雪花数据库。我想知道在fivetran中是否有任何选项，使得只将这些csv文件的向上插入(仅修改的行)同步到雪花表？
浏览 47提问于2021-11-12得票数 1
我想知道如何在雪花云数据库中创建和加载类型2(缓变)维度表。在大多数情况下，此表的加载涉及每天更新和插入多达1-50条记录。如果我们遵循传统的方法，那么雪花存储将在快照时间内显着增长，因为每一个小的变化都会为每个负载创建一个单独的存储。
浏览 0提问于2020-01-10得票数 0
在雪花上，更新对象的唯一方法是通过对象插入，但我需要使用来自另一个表的联接来更新这些对象。如何在雪花上加入object_insert？
浏览 4提问于2022-01-10得票数 3
我是AWS和snowflake的新手。我希望从S3加载csv文件到各自的雪花表(大约100个表)使用亚马逊网络服务胶水。我可以使用下面的文章将数据加载到一个雪花表中
是否可以使用1个aws glue来加载表格列表？
AWS Glue内部-我们可以编写逻辑来基于csv文件在snowflake中更新或插入数据吗？
请建议并分享任何示例代码/solutions，如果有。
谢谢，乔
浏览 0提问于2020-04-10得票数 0
(代表雪花用户提交)
当我将数据从甲骨文插入到雪花时，我将面临以下错误。有人知道为什么会出错吗？
Note: Error column defined "VARCHAR" datatype
我了解到，如果显式长度指定为VARCHAR(255)，则可能会遇到错误，因为(根据雪花文档)：“如果没有指定长度，则默认值是最大长度。”
单字节: 16,777,216
多字节: 8,388,608 (每个字符2字节)到4,194,304 (每个字符4字节)
我听说过，在Oracle中，我可以将数据类型和长度更改为VARCHAR2(4000)，或者在雪花中更改为默认的VARCHAR，而无需
浏览 3提问于2019-10-14得票数 1
回答已采纳
1回答
(代表雪花用户提交.)
我有有8800万行的表和有28个不同值的日期应用聚类，但是当我检查聚类信息和聚类深度时，雪花将所有数据放在一个分区中，聚类比率为零。我遵循雪花文档来创建集群表并将数据插入到表中。有什么问题吗？我错过的任何一步都不是文档的一部分？是否需要在帐户级别启用群集？
最近的建议：
对于早于自动群集的客户，必须使用alter table t1 resume recluster;手动启用重新群集，否则只需设置群集键即可启用重新群集。
首先，检查来自SHOW TABLES的列SHOW TABLES；
接下来，检查AUTOMATIC_CLUSTERING_HISTORY()
浏览 4提问于2019-10-15得票数 0
回答已采纳
我们“需要”用数据(通过ODBC提供SSAS表格模型，因为我们没有雪花连接器)。
我们尝试了SQL Server 2016和Server 2017，获得了糟糕的性能(每秒几行.)。
在PowerBI下，有一个雪花连接器，而且速度很快。
当我试图将雪花数据提供给SAS时，我遇到了一个，有人遇到了一个明显类似的速度问题。
他似乎通过指定一些(ODBC?)来解决他的问题。参数：
dbcommit = 10000
自动提交=否
重新接纳= 200
插入物= 200
这些参数是雪花特有的吗？或者只是ODBC？
谢谢
埃里克
浏览 1提问于2019-11-28得票数 1
回答已采纳
在雪花中，如果我运行如下命令：
create temporary table "Tab" (i int);
select * from "Tab"; -- this works
select * from Tab; -- error
我得到以下错误：
SQL编译错误:对象'TAB‘不存在或未授权。
雪花的声称，未引用的对象标识符不区分大小写。如果是这样的话，为什么要寻找TAB呢？为什么它不认识到Tab (或TAB)指的是与"Tab"相同的东西
浏览 5提问于2021-05-14得票数 0
回答已采纳
我使用cursor.executemany从其他来源插入数以千计的行到雪花数据库。那么，如果插入由于某种原因而失败，它会回滚所有插入吗？
有没有办法只在同一行还不存在的情况下才插入？表中没有主键，也没有唯一键
浏览 0提问于2020-05-31得票数 0
也许是个新手的问题，但这是我第一次尝试用BI工具连接雪花。我在雪花上创建了一个30个试用帐户(与任何组织无关)，并试图从Power和Tableau (桌面)连接，但插入凭据后我收到了一个登录错误。来自Power BI：
详细信息："ODBC: HY000 REST请求失败: HTTP错误(http错误)- code=405。
来自Tableau：
*与雪花通信时出现错误，用户名或密码无效。错误代码: 2438FAD7雪花(4) REST请求失败: HTTP错误(http错误)- code=405。*
我使用app.snowflake.com作为服务器，我的用户名和密码作为凭证。用
浏览 14提问于2022-02-26得票数 1
我正试图在雪花中设置连续的数据复制。我得到在源系统中发生的事务，我需要以与源系统相同的顺序在雪花中执行它们。我试图为此使用MERGE，但是当源系统中的同一键上有多个操作时，MERGE不能正常工作。它要么错过一个操作，要么返回在DML操作错误期间检测到的重复行。
请注意，事务需要按准确的顺序进行，并且不可能将最近的事务作为密钥而只执行它(就像记录已经被插入和更新一样，在雪花中，它也需要先插入，然后更新，即使insert只是暂时状态)。
下面是一个例子：
create or replace table employee_source (
id int,
first_name varchar(255
浏览 2提问于2022-10-18得票数 0
我试图使用Python脚本将数据从Oracle BLOB列迁移到雪花数据库表。我能够通过从Oracle提取数据并加载到雪花DB来创建csv来迁移所有其他数据类型的数据。有人知道如何使用Python脚本实现这种迁移吗？谢谢。
浏览 3提问于2021-03-15得票数 1
我正在填充一个20列的表，我想把记录除以6千万。因此，1-60,000,000条记录的col20值将是“1”，61,000,000-120,000,000条记录的值为“2”，等等。
我正在采取以下步骤：
填充19列，将col20保留为空创建临时表，将所有记录删除所有从表插入到表select *，1+层(ROW_NUMBER() OVER (order by col1) -1/60000000)作为col20从temp中删除
我不太熟悉雪花的表演，我只是觉得删除所有和重新插入看起来愚蠢和没有效率。还有其他方法可以做到这一点吗？或者，在表演方面，这不是雪花的问题？
更新:我的意思是-表没有主键/唯
浏览 2提问于2021-09-23得票数 0
我想从C#的雪花数据库中获得更新/插入的计数，但我不清楚这是否可能。当然，我的ODBC DB客户机允许这样做，但是SnowflakeDbCommand.ExecuteReaderAsync返回一个空的结果集。任何想法都很感谢。
浏览 19提问于2020-11-29得票数 0
我是dbt的新手，我正在尝试编写一个数据模型，将其结果插入到现有的雪花表中。下面没有配置的代码在雪花上平稳运行，但在dbt上不工作。似乎插入语句没有在DBT中使用？
{{ config(materialized = 'view') }}
INSERT INTO "v1" ("ID", "Value","Set",ROWNUM )
with LD as(
select "ID",
"Value",
浏览 9提问于2022-02-24得票数 1
1回答
我正在尝试使用dbWritetable()向雪花数据库表插入一个R数据。它只是插入了几行，而不是整个数据帧。
错误: result_insert_dataframe(rs@ptr，value，batch_rows)中的错误: nanodbc/nanodbc.cpp:1655: 00000:雪花(40465)字符串数据在执行转换时被截断。
浏览 7提问于2022-04-12得票数 0
2回答
有时，当我从雪花表中选择一个列时，我需要使用双引号或它区分大小写，但在其他情况下，它不是。
我对雪花很陌生。
为什么某些列会区分大小写？
在select语句中使用时，列名中的哪些字符将要求我以双引号列出整个列名？
浏览 4提问于2021-05-12得票数 2
回答已采纳
1回答
我在雪花中放置表，在那里我使用雪管从AWS S3复制数据。其中一些记录是一种创建事件和多个更新的类型。对于同一事件，将有一个创建和多个更新事件的时间顺序。我想将这些记录移到另一个表中(所以create事件应该将一个记录插入到一个表中，多个更新事件应该相应地更新这些记录。)我试图使用“合并”概念雪花，但是它不适合我的用例，就好像我的目标表没有记录一样，它为每个创建和更新创建一个新记录。
浏览 0提问于2019-12-16得票数 0
我们有一个带有逗号分隔符的CSV文件，该文件被加载到预暂存表中(总共50列)，而我们尝试插入到另一个表中(30列)，不需要将20列插入到表中，我们得到的是冲突行匹配
请建议我，如何使用雪花存储过程或java脚本。
提前感谢！
浏览 4提问于2021-09-01得票数 1
我正在将数据加载到雪花数据库建模的数据库中。在更新行的字段时，该模型的工作方式如下：
current_timestamp().Add 将此行的加载结束日期设置为等于同一行，再将新值设置到模型中。
我正在使用来自雪花的merge命令在一个JavaScript过程中这样做：
var observarion_query = "MERGE INTO HUB_OBSERVATION AS OBS "+
"USING (SELECT DATE(T.$"+OBSERVATION_DATE+", 'DD/MM/YYYY') AS OBS_DATE, T.
浏览 3提问于2021-01-20得票数 1
我想在雪花数据库表中插入一个数据帧。数据库中有像id这样的列，这是一个primary_key，event_id是一个integer字段，它也是nullable。
我已经使用declarative_base() SQLAlchemy创建了一个类，如下所示-
class AccountUsageLoginHistory(Base):
__tablename__ = constants.TABLE_ACCOUNT_USAGE_LOGIN_HISTORY
__table_args__ = {
'extend_existing':True,
浏览 7提问于2020-12-23得票数 0
回答已采纳
1回答
有人知道如何将R数据帧写入新的雪花数据库表吗？我在R中创建了一个成功的雪花ODBC连接，并且可以成功地从雪花查询。连接命令是: conn <- DBI::dbConnect(odbc::odbc()，“雪花”)。
现在，我想写一个在R中创建的数据帧，作为一个表返回给雪花。我使用了以下命令: dbWriteTable(conn，"database.schema.tablename"，R数据帧名)。使用此命令成功地与雪花连接，但我得到以下错误消息：“new_result中的错误(connection@ptr，语句)：nanodbc/nanodbc.cpp:1344: 2200
浏览 9提问于2020-06-04得票数 3
回答已采纳
我正在尝试从雪花数据库中的另一列中添加新创建的列的值，可以有人帮助吗？我希望在CompanyID中插入OrderID列的值 ?
浏览 14提问于2021-10-29得票数 1
回答已采纳
1回答
多租户中雪花簇的安全性
、、、
对于具有雪花的多租户环境，每个客户端都有不同的集群。我们如何通过DDoS攻击保护雪花集群？由于我们拥有跨租户的通用微服务，而不是一个租户可以恶意地对另一个雪花集群进行DDoS攻击。如何在租户雪花集群之间配置网络隔离？
谢谢
浏览 14提问于2022-01-10得票数 1
3回答
我想把雪花和动力BI联系起来。我已经下载了ODBC驱动程序，但是当我用我的Microsoft帐户登录到雪花连接器时，会发现一个错误。我用AD登录到雪花。
这是一个错误：
段Section1；
共享Snowflake.Databases("XXXXXXXXXazure.snowflakecomputing.com"，Query1 = let Query1=CreateNavigationProperties=null "XXX_XXX_XXXX"，CreateNavigationProperties=null，ConnectionTimeout=null
浏览 4提问于2020-04-16得票数 0
回答已采纳
我有一张雪花桌A如下：
CREATE or replace table A
(
Address VARCHAR(50),
Zip VARCHAR(50));
insert into A (Address, Zip) values
('ABC', '20987'),
('XYZ', '20989'),
('CBZ', '20980');
我有一张空的雪花桌，如下所示
CREATE or replace table B
(
Address VAR
浏览 4提问于2022-08-04得票数 0
1回答
据我所知，底层文件(列格式)是不可变的。我的问题是，如果文件是不变的，更新是如何执行的。雪花是否维护同一行的不同版本，并根据键返回最新版本？还是将数据插入场景后面的新文件并删除旧文件？如何在这些场景中影响性能(查询当前数据)，如果时间旅行设置为90天，因为雪花需要维护同一行的不同版本。但是由于雪花不尊重键，所以即使是不同的版本也会被检测到。任何关于内部细节的见解(文件/视频)都将不胜感激。
浏览 0提问于2018-02-07得票数 7
回答已采纳
嗨，我对雪花有这个问题。我在雪花SP中有一些插入语句，如下所示：
DROP TABLE TABLE1;
CREATE table TABLE1 (COLUMN1 VARCHAR(10));
insert into table1 values('TEST' || TRIM(0));
当我执行这些语句时，会得到如下错误：SQL compilation error: Invalid expression ['TEST' || '0'] in VALUES clause
雪花中的值子句是否有文档记录的限制。有什么工作要做吗？
浏览 5提问于2020-11-22得票数 0
回答已采纳
当试图将数据插入雪花表时，假定类型的不正确的强制转换输入值可能会覆盖表创建命令提供的数据类型。例如，给定如下创建的表：
CREATE TABLE vctable (
itemA VARCHAR(8),
itemB VARCHAR(8)
);
以下命令失败：
INSERT INTO vctable (itemA, itemB) VALUES ('hi','ho'), (1,2);
ERROR: Numeric value 'hi' is not recognized
我预计此插入会失败，因为第二条记录的数据类型与表定义不匹配(正如预
浏览 6提问于2021-12-10得票数 2
回答已采纳
我有一个，其中包含几个列是列表。我想将它们作为ARRAY数据类型插入到我的雪花表中。
传统上，我使用PostgreSQL，并将其插入为df_to_insert.to_sql(TABLE_NAME, sqlalchemy_connection, **other_parameters)。
然而，我正在努力插入雪花。当我有一个列是一个列表时，sqlAlchemy雪花方言相信它是一个字符串：
表达式类型与列数据类型不匹配，需要数组，但获得了列NAME_OF_COLUMN_WITH_LISTS的VARCHAR(2)
通过添加显式的dtype，我尝试给sqlAlchemy引擎一个提示，说明该列不是
浏览 0提问于2019-04-14得票数 6
为了节省存储成本，我们计划从Aurora/Mysql迁移到Snowflake，用于我们存储审计相关信息的用例之一。我们将所有审计信息存储在Aurora中，以便在将此Aurora合并到应用程序中时提供毫秒延迟。
我们确实有大量的审计信息，大小为12 TB，而且还有文本列，而且还在不断增长。现在，为了节省成本并考虑到未来的增长，我们正在探索其他选择，当我们可以节省资金时，性能也可以匹配。虽然做研究凸轮了解Snowflake，我们正在做POC，但我观察到在主键上搜索ID并不能给我们带来与Aurora Mysql相同的性能。
所以想要一些专家的建议，我们如何使雪花作为我们的应用程序后端，我可以做插入/
浏览 0提问于2020-10-13得票数 0
嗨，我对雪花很陌生，我正试图用存储过程将一个2D数组插入到雪花中的表中。
数组看起来如下[名称，最后，年龄，名称，最后，年龄.]有几千件物品。
我试着使用INSERT INTO使用一个循环，但它只需要很长时间。我需要一个更快的方法来插入数据。知道怎么处理这个吗？
浏览 1提问于2020-06-25得票数 0
我正在使用雪花jdbc，并试图通过传递无效的仓库名称并在默认仓库中创建表，从而在雪花中创建表。
String jdbcUrl = "jdbc:snowflake://<identifier>.snowflakecomputing.com?warehouse=invalid_warehouse&db=db&schema=schema&role=role";
Connection conn = null;
Statement st = null;
try {
conn = D
浏览 5提问于2022-07-12得票数 1
2回答
我试图从文件名中提取日期(20200222)，同时在雪花中复制命令。
文件名
s3://hadoop/2020002/dbo.DOSSIER_TRANSPORT_20200222.csv.gz
雪花查询
SELECT regexp_substr(metadata$filename, '/(_((\-|\+)?[0-9]+(\.[0-9]+)?).)/' as data FROM '@PRD.OPE_STG
_CMD.SPX_PRD_CMD/' (file_format
浏览 9提问于2020-02-24得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
