sqlserver的CDC第一次查询的能读取到数据，但后面增删改读取不到，是什么原因
SQL Server的CDC (Change Data Capture) 可以在数据更改时自动捕捉更改并将其存储到另一个数据源，例如，存储到 SQL Server 本身或者存储到数据仓库中。然而，如果第一次查询能够读取到数据，但后来增删改更改就无法读取到了，这可能是由于以下几种原因：
- 数据更改时，并没有触发 CDC 的捕获机制，这意味着更改并没有被记录到 CDC 的历史记录中。这可能是由于 SQL Server 没有使用足够的权限或者没有启用 CDC 捕获，也可能是由于用户对数据库的操作不正确，导致数据更改没有被及时发现。
- 数据更改时，数据格式不正确，或者数据类型不匹配，这可能导致 CDC 捕获不到数据的更改。如果使用非标准的数据格式，需要确保数据格式是兼容的，以确保可以正确记录数据更改。
- 数据更改的过程中，存在网络延迟或者中断的问题，这可能导致 CDC 无法捕获到数据更改。如果数据库所在的主机存在网络延迟或者中断，可以采取一些措施来解决网络问题，例如优化数据库架构、使用负载均衡等。
- 数据库中可能存在某些特殊索引，它们能够影响 CDC 的捕获机制。可以尝试禁用这些索引，或者修改索引的创建方式和查询方式来确保 CDC 能够正常工作。
如果以上方法还是无法解决您的问题，您可以考虑联系 SQL Server 的技术支持团队或者数据架构师，以获取更好的帮助和建议。
相关·内容
1回答
嗨，我正在尝试将远程Server上的所有表导入到KSQL主题--这是我的文件属性
connector.class=io.confluent.connect.cdc.mssql.MsSqlSourceConnector
name=sqlservertest
tasks.max=1
initial.database=$$DATABASE
connection.url=jdbc:sqlserver://$$IP:1433;databaseName=$$DATABASE;user=$$USER;
username=$$USER
password=$$PASS
server.name=$$IP
serv
浏览 0提问于2018-10-10得票数 1
我已经在Tomcat上托管并运行了我的应用程序war，它已经处于良好状态几个月了。tomcat配置或其他与环境相关的更改(如机器上的java版本或war本身)最近没有发生任何更改。此外，服务器上的负载不会突然或迅速增加，因为它是一个孤立的环境。就在最近几天，客户机对服务器的调用挂起了客户机，服务器上的跟踪显示，
java.net.SocketInputStream.socketRead0(Native Method)
java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
java.net.SocketInput
浏览 0提问于2018-12-14得票数 0
1回答
我有一个MVC网站，它在本地运行得很好，但是当我向Azure发布时，我得到了一个错误：
Could not load file or assembly 'EntityFramework.SqlServer' or one of its dependencies. The module was expected to contain an assembly manifest.
一旦我导航到网站的登录页面。
自从上一次成功发布以来，我已经更新了一些NuGet包，所以我认为服务器上的EntityFramework.SqlServer.dll版本可能是错误的，但是在发布过程中肯定应该更
浏览 3提问于2015-04-24得票数 0
回答已采纳
我想知道是否有任何方法可以找出最近的事件何时写入Server中的表。
假设表没有已创建的_at/updated_at列，并且在表上不启用CDC和Capture。
我不想将数据从这种方法中流出来；我知道我可以使用CDC或CT来这样做，但我正在试图找到一种方法来检查表X是否处于活动状态，并且只有用于监视目的的插入/更新。我不想要写入的实际数据，我只想要一个时间戳，表示表受到了insert或update的影响。
我一直在检查sys.tables，我发现了create_date和modify_date这样的列，但是它与表的存在和模式更改有关，而不是底层数据，但它给了我希望，它可能在Server的一个无
浏览 0提问于2021-11-29得票数 -1
当我查看一份关于以太扫描或bscscan的合同时，就有可能读取该合同，这基本上就是合同的一个公共功能。但是，当我通过以太扫描或bscscan接口读取合同时，msg.sender使用了什么值？
浏览 0提问于2021-09-11得票数 3
我正在尝试一次读取多个文本文件。其中第一行是文本文件之间的区别，而文本文件名称是相同的。我正在使用下面的代码，它只能读取一个文本文件，而不能读取整个文件。请帮帮我。下面是我的控制器代码
def index
Dir.chdir("/home/sbrc/sukanta/opengrok")
@f = Dir.glob("**/*.txt")
i = 0
@params = []
while i<@f.length
data = IO.readlines("/home/sbrc/sukanta/opengrok/"
浏览 0提问于2013-09-04得票数 0
我有一个java程序，它只能读取12的文件。
Reader reader1 = new FileReader(filePath);
try (BufferedReader bufferedReader = new BufferedReader(reader1)) {
String line = bufferedReader.readLine();
while (line != null) {
line = bufferedReader.readLine();
}
浏览 5提问于2016-04-27得票数 1
我正面临着一个问题，我找不到解决办法。我正在使用Hibernate envers来审计一个表(我使用MS作为数据库)。
当我试图更新表时，会得到一个错误：
“-”附近的com.microsoft.sqlserver.jdbc.SQLServerException:语法不正确。“
有什么帮助吗？谢谢
浏览 0提问于2016-06-30得票数 0
环境: Eclipse + sts
我新建了一个Spring Starter项目，我选择了JDBC API，MS SQL Server Driver，Spring Web Starter。
在它第一次创建时，会出现如下错误：
Multiple annotations found at this line: - Plugin execution not covered by lifecycle configuration: org.apache.maven.plugins:maven-resources-plugin:3.1.0:testResources (execution: def
浏览 20提问于2019-07-05得票数 0
以下Java中的简单代码以一种我无法理解的奇怪方式运行。
final public class Main
{
public static void main(String[] args)
{
Scanner sc = new Scanner(System.in);
System.out.print("\nHow many names? ");
int n = sc.nextInt();
String[] a = new String[n];
a[0] = sc.nextLin
浏览 3提问于2011-11-07得票数 0
回答已采纳
我正在尝试从CDC 500 cities API中读取数据，以便集成到更大的空间分析中。我正在使用arcpy和其他几个库编写一个python脚本。 三大步骤是: 1.读取数据并将数据转换为适当的格式2.将数据连接到人口普查区域shapefile 3.将交叉点制表以重新计算到ZCTA级别 但是，有一些格式问题，它不能执行连接表工具。 我刚接触python，但我尝试过使用response.read()读取数据，也尝试过通过json.dumps()和json.loads()使用json库，但这两种方法似乎都不能满足我的要求。 这就是我现在所拥有的： Url="https://chronic
浏览 18提问于2019-04-10得票数 0
2回答
SSIS CDC控制任务
、、、
我正在为SSIS CDC组件的使用做一个概念证明。
对于初始加载:到目前为止，我得到的是
步骤1: CDC控制任务与CDC控制操作为:标记初始加载开始步骤2:将所有源记录加载到目标的数据流步骤3: CDC控制任务与CDC控制操作为:标记初始加载结束(步骤1中CDC设置的其余部分)
当我第一次跑步的时候...所有数据加载正常。如果运行相同的命令...取而代之的是不选择任何记录(源不变) ...它会再次重新加载所有记录。复制中。
这样做不会检入在步骤1中创建的CDC状态表。
任何人都可以给我指出好的样本或教程将是伟大的。
浏览 0提问于2013-03-08得票数 1
回答已采纳
我使用Debezium CDC SQL Server源连接器从SQL server获取数据并将其放入Kafka中，我使用的配置是
name=ds1
connector.class=io.debezium.connector.sqlserver.SqlServerConnector
tasks.max=1
database.server.name=server2
database.hostname=localhost
database.port=1433
database.user=sa
database.password=Password!
database.dbname=demo
#tabl
浏览 0提问于2020-06-26得票数 0
我有一个包含10个工作表的Excel工作簿，每个工作表都有一个国家名称。所有图纸的第一行都是相同的。我需要的是在R中将它们连接到一个单独的数据帧中。我一直在使用"readxlsx“库，但我一次只能读取一个工作表，而且我仍然不知道如何将它们连接起来…… 任何帮助都将不胜感激。
浏览 19提问于2021-04-07得票数 1
回答已采纳
1回答
当我尝试在ubuntu上运行带有多个测试用例的cpp代码时，我得到了意想不到的结果。当我一个接一个地运行测试用例时，它工作得很好，但是当我复制和粘贴测试用例时，terminal会出现意外的换行
例如
#include<bits/stdc++.h>
using namespace std;
int main(){
int t;
cin>>t;
while(t--){
int n;
cin>>n;
cout<<n<<"Hello"<<endl;
}
}
浏览 10提问于2021-01-08得票数 1
1回答
我正在使用sdk恢复数据库。在还原完成之前，sqlRestore方法不会阻塞。我已经通过尝试在还原后直接访问还原数据库来测试这一点，并且我得到了数据库正在恢复的一个错误。我尝试过调用等待函数。
我的代码如下：
Server sqlServer = new Server("reddsql01");
Restore dbRestore = new Restore();
dbRestore.Devices.AddDevice(@"Z:\Test Folder\database.bak", DeviceType.File
浏览 2提问于2015-02-19得票数 1
回答已采纳
我在csv文件中的不同工作表中维护数据，但现在我想通过jmeter读取此数据。我知道如何在jmeter中读取单个csv文件，因此需要帮助才能读取单个csv文件中的不同工作表。
有没有人能帮我解决这个问题？
浏览 2提问于2013-05-30得票数 0
1回答
我是powershell脚本编程的新手。我正在尝试使用powershell执行SSIS。但是在Add-Type -AssemblyName上得到了错误。找不到程序集。我将dll保存在powershell脚本所在的文件夹中。不能读取dll的原因是什么？
Add-Type -AssemblyName "Microsoft.SqlServer.ManagedDTS, Version=11.0.0.0, Culture=neutral, PublicKeyToken=89845dcd8080cc91"
$ssisApplication = New-Object "M
浏览 0提问于2018-06-19得票数 0
1回答
我有一个很大的文本文件，我用pd.read_csv读取了它。但它不能读取数据帧中的特殊行并返回该行的NAN值。我知道，如果我在行中添加一个空格，一切都会正常工作。但是我不能这样做，因为我的文本文件的格式根本不能改变。有没有人在处理大的文本文件时遇到了同样的问题？ 我认为在这里不可能发送文件，但如果您认为您可以找到解决方案，我可以将我的文件和代码通过电子邮件发送给您。 提前谢谢。
浏览 11提问于2021-04-14得票数 0
我有如下所示的文本文件。我使用fscanf读取，直到它看到“line”，然后将该行中的其他所有内容读入数组中。
text text some words text
text hello text text
text text random text
world
found read1 read2 read3
don't
read any of this
到目前为止，我有以下几点：
while(fscanf(file, "%s", var) != EOF){
if(strcmp(var, "found") == 0){
//pu
浏览 5提问于2017-10-14得票数 1
回答已采纳
我尝试使用以下代码：
Shell(nppPath & " " & fileToOpen, vbNormalFocus)
它打开txt文件nppPath = "C:\Windows\notepad.exe"，但我不能读取它，并将其保存为.txt文件使用VBA。
期待您的建议。
浏览 13提问于2018-07-25得票数 0
回答已采纳
Cassandra版本: 3.11
我已经在cassandra.yaml中启用了cdc：
cdc_enabled: true
cdc_raw_directory: /var/lib/cassandra/data/cdc_raw
并启用了该表：
cqlsh> describe cycling.cyclist_name;
CREATE TABLE cycling.cyclist_name (
id uuid PRIMARY KEY,
firstname text,
lastname text
) WITH bloom_filter_fp_chance = 0.01
浏览 4提问于2020-01-29得票数 2
我是第一次使用SQLite3，我找不到下面的错误。以下是相关的台词：
//open db; I checked, and sqlite3_open() returns 0 here (SQLITE_OK)
rc = sqlite3_open(filename.c_str(),&db);
//...
//create & prepare query.
string query = "SELECT * FROM MOCK_DATA;"; //I am positive MOCK_DATA exists and is non empty
sqlite3_stmt*
浏览 4提问于2014-10-02得票数 1
回答已采纳
1回答
在cassandra中存储小文件
、、、、
cassandra-cli中是否有API(Thrift或Hector)或一些命令的示例，用于解释如何在Cassandra中存储小文件(几百KB)。
我试过用谷歌搜索，但什么也找不到。
浏览 1提问于2012-05-17得票数 1
我的程序将要求用户输入他/她的名字。目前，我的扫描器对象只能读取一个单词。但是，如果用户输入多个单词(假设某人的全名)，则会引发异常。如下所示：
我怎么才能解决这个问题？
我的代码：
public class BankApp_Assignment {
public static void main(String[] args) {
Scanner sc = new Scanner(System.in);
int userChoose;
String name = null;
int accNum =
浏览 2提问于2015-04-03得票数 1
回答已采纳
2回答
public static void parseit(String thexml){
SAXParserFactory factory = SAXParserFactory.newInstance();
SAXParser saxParser;
try {
saxParser = factory.newSAXParser();
DefaultHandler handler = new DefaultHandler() {
public void startElement(String uri, String
浏览 5提问于2010-02-12得票数 4
回答已采纳
1回答
这是我背后的asp.net代码：
public string ReadJSON(string jsonPath)
{
FileStream fs = new FileStream(jsonPath, FileMode.Open, FileAccess.Read);
StreamReader sr = new StreamReader(fs);
string WillReturn = "";
try
{
WillReturn = sr.ReadToEnd();
浏览 1提问于2013-09-25得票数 0
1回答
我使用下面的代码在我的本地主机上流式播放一部电影。小于2 2GB的电影工作正常，但是当电影大于2 2gb时，电影就不能播放了。
请告诉我应该怎么做才能读取更大的文件。
这是我用于流媒体电影的代码
<?php
//Determine file path according to extension
if (!isset($_GET['ext']) || $_GET['ext'] == 'mp4') {
$path ='movies/'.$_GET['movie'];
}
$finfo = new
浏览 0提问于2018-09-27得票数 0
如何将pdf文件插入sqlserver2005并从sqlserver读取pdf文件？
浏览 18提问于2009-02-21得票数 5
1回答
我想要读取多个NFC标记并同时执行操作，
例如：
禁用wifi
禁用蓝牙
振铃体积变化
报警变化
但我的红色，它只执行了一个动作，我们进入了第一次。
有没有可能读取多个标签并同时行动？
浏览 0提问于2016-12-12得票数 0
我找到了9990的“缓冲区缓存命中率”意味着什么？ (我从一个博客中得到了9000+的结果)，并使用LowlyDBA/Denis解决方案与丹尼斯·戈博的PLE检查器相结合，缓冲区缓存命中率为100%，PLE为103，这怎么可能？
缓冲区缓存命中率为100%，表示所需的100%页面在内存中找到，而PLE则表示页面仅在内存中停留几分钟。
也许有一些PLE值，低于哪个缓冲chache命中率不增加价值？
SELECT (a.cntr_value * 1.0 / b.cntr_value) * 100.0 as BufferCacheHitRatio
FROM sys.dm_os_performance
浏览 0提问于2019-04-18得票数 2
回答已采纳
我们有一个问题，有时会发生，但会经常发生。当我们为特定的表运行sqoop导入时，有时它在5分钟内完成。有时需要2.5小时。在这种情况下，我们总是看到一个失败的地图任务，需要大约2小时10分钟。你能帮我解决这个问题吗？
1)失败的任务总是失败，出现以下错误。当预期出现以下错误时，我们能否在10-15分钟内完成映射任务，而不是等待2小时。
"2018-03-06 00:09:41,485错误主org.apache.sqoop.mapreduce.db.DBRecordReader:顶层异常: com.microsoft.sqlserver.jdbc.SQLServerConnection
浏览 0提问于2018-03-06得票数 0
我们正在尝试为Server (mssql)中的几个表设置一个SQL-Server->Debezium->Kafka Connect->Kafka Pipeline设置
启动安装程序后，将获得以下错误:日志：
{
"name": "mssql-server-uat",
"connector": {
"state": "RUNNING",
"worker_id": "172.17.0.3:8083"
},
"tasks":
浏览 3提问于2020-05-12得票数 0
回答已采纳
关于servlets中的HttpResponse对象的问题。HttpResponse的内容只能读取一次吗？
如果是这样，我是否需要使用一个过滤器和某种形式的"javax.servlet.http.HttpServletResponseWrapper“来读取HttpResponse对象的内容，因为我需要读取其内容以从响应中检索XML/JSON？目前，当我去读取HttpResponse对象时，我得到了下面的异常。
Content has been consumed
at org.apache.http.entity.BasicHttpEntity.getContent(Basic
浏览 2提问于2011-03-16得票数 0
3回答
为了捕获删除的用户名，我在CDC表中添加了一个新列(例如：- SQL )来设置记录的cdc.dbo_testCDC_CT用户名。即ALTER TABLE cdc.dbo_testCDC_CT ADD username VARCHAR(20) DEFAULT(SUSER_SNAME())。该列中的值始终是"sa"，但我是以windows身份验证登录的。为什么会发生这种情况？
浏览 9提问于2014-10-29得票数 0
我需要从Oracle表中读入此XML COLB列。我尝试了下面这样的简单读入： xmlbefore <- dbGetQuery(conn, "select ID, XML_TXT from XML_table") 但我只能读入大约225,000个字符。当我与示例XML文件进行比较时，它可能只读入整个字段的2/3或3/4。 我假设R有大约225,000个字符的限制，而SAS的限制更少，大约只有1000个字符。 如何读取包含所有字符的整个字段(我认为大约是250,000-270,000)？
浏览 17提问于2019-12-12得票数 0
2回答
我正试着用
getline(cin, x)
在for循环中。
但是，在第一次运行时，它只返回一个空行。
有很多这样的问题，我都试过了
cin.ignore() and cin.clear()
按照建议，甚至尝试在两者之间再使用一条getline来清除缓冲区，但无济于事。
还有没有其他的把戏？
谢谢
char x;
cin >> x;
int y, z;
cin >> y >> z;
cin.ignore(numeric_limits<streamsize>max(), '\n');
for (int a = 0;
浏览 1提问于2014-02-06得票数 1
2回答
我想问6位数字的引脚从用户，我尝试了这个代码，它确实工作。问题是它不能读取从0开始的pin。该代码的目标是读取6位引脚，无论起始是什么，只要它是一个整数，它就会读取正确的输出。
using namespace std;
int main(){
int pin[0];
cin>>pin[0];
if (pin[0] >= 100000 && pin[0] <= 999999) {
cout << pin[0];
}
else {
cout << "
浏览 0提问于2021-10-13得票数 0
2回答
我创建了一个简单的类，它向服务器发送一个字符串，这两个类都使用Java进行通信。服务器读取客户端发送的内容，并使用另一个字符串进行响应。但是客户不能读到那个回应。
这是客户端类：
import java.io.IOException;
import java.net.Socket;
public class Client {
public static void main(String[] args) throws IOException {
Socket socket = new Socket("localhost", 8181);
浏览 4提问于2016-09-25得票数 0
回答已采纳
1回答
我有一个1 1GB的json文件，我想用python中的simplejson来解析它。因此，我编写了一个简单的代码，如下所示，运行良好
import simplejson
f=open('stem.json','r')
content=f.read()
data=simplejson.loads(content)
上述代码的问题在于它不能读取'utf-8‘格式的数据
所以我重写了下面的代码
import simplejson
import codecs
f=codecs.open('stem.json','r',enco
浏览 1提问于2012-03-12得票数 0
回答已采纳
我正在尝试阅读一些Rss / Atom提要
var synFeed = SyndicationFeed.Load(reader);
但它抛出了最小的问题。例如，当一个条目在description字段中包含几个HTML标记时，根本不可能读取Feed。它也不喜欢来自例如SlashDot的RDF标签。
请注意，Load()是一个没有重载的静态方法。
有没有其他方法可以使用System.ServiceModel.Syndication.SyndicationFeed?导入提要我找不到它。
顺便说一下:我使用的是C# 4，但是任何Framework3.5的答案也很好。我知道Argotic和其他库，我只想
浏览 0提问于2009-06-14得票数 2
回答已采纳
我在一个文件中有以下内容： A(3#John Brook)
A(2#Allies Frank)
A(1#Lucas Feider) 我想零碎地读一下这行。首先，我想按顺序阅读。例如，A比3比约翰·布鲁克好。3点之前一切都很好，但是如果没有"#“和")”作为字符串，我怎么能读到John Brook呢？ 我有一个函数，你可以看看我的代码： void readFile()
{
ifstream read;
char process;
char index;
string data;
read.open("datas.txt");
浏览 55提问于2021-10-28得票数 1
回答已采纳
使用c#，.Net Framework4.5
尝试用下面的代码创建简单的程序：
enum DataProvider { Sqlserver, Obdc, Oledb, None }
class Program
{
static void Main(string[] args)
{
Console.WriteLine("simple database connection factory");
IDbConnection Idbc = GetConnection(DataProvider.Sqlserver);
浏览 3提问于2013-11-25得票数 0
1回答
我正在开发一个能读入一个巨大的文本文件(最大可达5 5gb )的应用程序。目前，我正在使用fscanf读取文件，因为我发现它是迄今为止最快的。但是，读取整个文件仍然需要相当长的时间。
有没有更快的方法从文件中读入数据？
浏览 3提问于2012-07-31得票数 2
第一次尝试在Windows下运行一些Java代码时，我得到了：
D:\Tmp>java JDBC_SQLServer
Picked up _JAVA_OPTIONS: -Xmx512M
java.lang.ClassNotFoundException: com.microsoft.sqlserver.jdbc.SQLServerDriver
at java.net.URLClassLoader.findClass(Unknown Source)
at java.lang.ClassLoader.loadClass(Unknown Source)
浏览 31提问于2018-02-16得票数 0
回答已采纳
4回答
未提交的读物？
、、、
我正在研究DB中潜在的并发问题，所以我去阅读。我找到了，它提到了对未提交数据的访问。
访问未提交的数据。应用程序A可能更新数据库中的值，应用程序B可能在提交该值之前读取该值。然后，如果A的值不是稍后提交的，而是倒排的，则B执行的计算是基于未提交(并且可能是无效的)数据。
什么..。我认为其他会话(相同的应用程序，甚至相同的线程)可以读取尚未提交的数据？我认为只有将数据写入未提交事务的连接/会话(我不确定我的术语)才能读取未提交的数据。
其他线程真的能读取未提交的数据吗？我计划使用mysql，但我可以使用sqlite
浏览 8提问于2009-10-13得票数 1
回答已采纳
你好，我需要处理非常大的二进制文件，所以我不能使用Assign()，Closefile()等函数。我想为它的Read()/Write()方法使用TFileStream。但是我有问题，因为我不能读回我写到流中的内容。我知道这个问题与编码有关，所以我认为我需要使用Unicode，而不是Ansi。但我还不知道该怎么做。有没有人能帮我举个例子？我知道如何对文件进行写/读，但这并不能帮助我解决问题。
浏览 0提问于2011-06-11得票数 1
4回答
在C中，如果我通过函数fgetc从文件中读取一行，可能会出现堆栈溢出。假设有人编写了一个程序，在特定文件的一行中输出一大行ASCII数据。如何将C程序中数据读到屏幕上？我知道我只能读，比方说一次读100个字，但我不知道如何从特定的位置开始阅读。
浏览 0提问于2009-10-25得票数 1
回答已采纳
如何将BufferedReader中的read()返回的整数转换为实际的字符值，然后将其附加到字符串？read()返回表示读取的字符的整数。当我这样做的时候，它不会将实际的字符附加到字符串中。相反，它将整数表示形式本身附加到字符串中。
int c;
String result = "";
while ((c = bufferedReader.read()) != -1) {
//Since c is an integer, how can I get the value read by incoming.read() from here?
response +
浏览 0提问于2011-10-15得票数 14
回答已采纳
1回答
我正在尝试用帐户初始化流模拟器。下面是我的flow配置文件：
{
"emulators": {
"default": {
"port": 3569,
"serviceAccount": "delphai"
}
},
"contracts": {
"DelphaiUsers": {
"source": "./cadenc
浏览 9提问于2022-05-23得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
云直播活动推荐
腾讯云开发者
