使用参数化IN子句时，N1QL查询超时 [英] N1QL Query times out when Using parameterized IN clause
本文介绍了使用参数化IN子句时，N1QL查询超时的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
使用Couchbase服务器4.1.0（和4.5），Java SDK 2.2.8（也尝试过2.2.7,2.3.1和2.3.3），我有一个利用二级索引的查询，该索引运行正常我在本地运行我的代码，甚至通过AWS服务器上的CBQ（CBQ大约需要3ms）。但是，在AWS上运行我的应用程序时，我得到一个 TimeOutException ，它只有一个查询超时，其他查询没有。请参阅下面的详细信息。
值得注意的是，我的Couchbase设置有3个桶。
示例文档：
bucketName：{
userName：User_A，
MessageContent：这是消息，
docType：msg，
ParentMsgId：1234，
MsgType：test，
expireTimestamp：1454975772613，
publishTimestamp：1455322362028，
id：145826845，
urls：[]，
subject：这是一个主题，
type：1，
GroupId：Group_1
}
二级索引：
CREATE INDEX`indexName`ON`buckName`（`ParentMsgId`，`docType`，`publishTimestamp `）使用GSI
从 N1qlQuery #n1ql（）中提取的示例查询
{statement：
从bucketName $ b中选择计数（*）为msgCount $ b，其中ParentMsgId没有丢失，docType ='msg'
和Par entMsgId IN $ parentId
和publishTimestamp介于$ startTime和$ endTime
，$ endTime：1470726861816，
$ startTime：1470640461816，
$ parenIds：[ msgstrJava代码 p>
public static final String COUNT_STATEMENT =select count（*）as count+
from bucketName+
其中ParentMsgId没有丢失+
和docType ='msg'+
和ParentMsgId IN $ parentIds+
和$ startTime和$ endTime之间的publishTimestamp;
public int getCountForDuration（Long startTime，Long endTime，Collection< String> parentIds）{
List< String> idList = new ArrayList<>（parentIds）;
JsonObject placeHolders = JsonObject.create（）
.put（parentIds，JsonArray.from（idList））
.put（startTime，startTime）
.put（ endTime，endTime）;
N1qlQuery query = N1qlQuery.parameterized（COUNT_STATEMENT，placeHolders）
N1qlQueryResult result = bucket.query（query）;
...
}
查询解释结果
cbq>将select count（*）解释为来自bucketName的msgCount，其中ParentMsgId没有丢失，docType ='msg'和ParentMsgId IN [01b88f7f-4de6-4daa-9562-a2c902e818ad]和publishTimestamp介于1466445409000和1466531809000之间;
{
requestID：61afcf02-3b3d-4c8a-aec6-b76c4c1f7b17，
签名：json，
结果：[
{
#operator：序列，
〜儿童：[
{
#operator：IndexScan，
index： indexName，
keyspace：bucketName，
namespace：default，
spans：[
{
Range： {
高：[
继承人（\01b88f7f-4de6-4daa-9562-a2c902e818ad \）
]，
包含：1，
低：[
\01b88f7f-4de6-4daa-9562-a2c902e818ad \
]
}
}
]，
使用：gsi
}，
{
#operator：平行，
〜child：{
#operator：Sequence，
〜children：[
{
#operator：Fetch，
keyspace：bucketName，
namespace：default
}，
{
#operator：过滤器，
条件：（（（（`bucketName` .ParentMsgId`）不缺少）和（（`bucketName` .docType`）= \msg \））和（（`bucketName` .ParentMsgId `）在[\01b88f7f-4de6-4daa-9562-a2c902e818ad \]））和（（bucketName` .publishTimestamp`）之间1466445409000和14665318090 00））
}，
{
#operator：InitialGroup，
聚合：[
count（*）
]，
group_keys：[]
}
]
}
}，
{
#operator：IntermediateGroup ，
汇总：[
count（*）
]，
group_keys：[]
}，
{
#operator：FinalGroup，
聚合：[
count（*）
]，
group_keys：[]
}，
{
#operator：parallel，
〜child：{
#operator：Sequence，
〜children：[
{
#operator：InitialProject，
result_terms：[
{
as：msgCount，
expr：count（*）
}
]
}，
{
#operator：FinalProject
}
]
}
}
]
}
]，
状态：成功，
指标：{
elapsedTime：2.748194 ms，
executionT ime：2.660232ms，
resultCount：1，
resultSize：3274
}
}
日志
java.lang.Thread.run（Thread .java：745）
org.eclipse.jetty.util.thread.QueuedThreadPool $ 3.run（QueuedThreadPool.java:533）
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob（QueuedThreadPool。 java：598）
org.eclipse.jetty.server.nio.BlockingChannelConnector $ BlockingChannelEndPoint.run（BlockingChannelConnector.java:293）
org.eclipse.jetty.server.BlockingHttpConnection.handle（BlockingHttpConnection.java： 50）
org.eclipse.jetty.http.HttpParser.parseAvailable（HttpParser.java:218）
org.eclipse.jetty.http.HttpParser.parseNext（HttpParser.java:582)
org.eclipse.jetty.server.HttpConnection $ RequestHandler.headerComplete（HttpConnection.java:919)
org.eclipse.jetty.server.HttpConnection.handleRequest（HttpConnection.java:441)
org.eclipse。 jetty.server.Server.handle（Server.java:349）
org.eclipse.jet ty.server.handler.HandlerWrapper.handle（HandlerWrapper.java:110)
org.eclipse.jetty.server.handler.HandlerCollection.handle（HandlerCollection.java:149）
org.eclipse.jetty。 server.handler.ScopedHandler.handle（ScopedHandler.java:117）
org.eclipse.jetty.server.handler.ContextHandler.doScope（ContextHandler.java:875)
org.eclipse.jetty.server。 session.SessionHandler.doScope（SessionHandler.java:186）
org.eclipse.jetty.servlet.ServletHandler.doScope（ServletHandler.java:409）
org.ops4j.pax.web.service.jetty。 internal.HttpServiceContext.doHandle（HttpServiceContext.java:117）
org.eclipse.jetty.server.handler.ContextHandler.doHandle（ContextHandler.java:941)
org.eclipse.jetty.server.session。 SessionHandler.doHandle（SessionHandler.java:227）
org.eclipse.jetty.security.SecurityHandler.handle（SecurityHandler.java:483）
org.eclipse.jetty.server.handler.ScopedHandler.handle（ ScopedHandler.java:119)
org.ops4j.pax.web.service.jetty.internal.HttpServiceServletHandl er.doHandle（HttpServiceServletHandler.java:70）
org.eclipse.jetty.servlet.ServletHandler.doHandle（ServletHandler.java:480）
org.eclipse.jetty.servlet.ServletHolder.handle（ServletHolder。 java：547）
org.apache.cxf.transport.servlet.AbstractHTTPServlet.service（AbstractHTTPServlet.java:201）
javax.servlet.http.HttpServlet.service（HttpServlet.java:693）
org.apache.cxf.transport.servlet.AbstractHTTPServlet.doGet（AbstractHTTPServlet.java:150）
org.apache.cxf.transport.servlet.AbstractHTTPServlet.handleRequest（AbstractHTTPServlet.java:225)
org.apache.cxf.transport.servlet.CXFNonSpringServlet.invoke（CXFNonSpringServlet.java:130）
org.apache.cxf.transport.servlet.ServletController.invoke（ServletController.java:194）
org。 apache.cxf.transport.servlet.ServletController.invokeDestination（ServletController.java:214）
org.apache.cxf.transport.http.AbstractHTTPDestination.invoke（AbstractHTTPDestination.java:237）
org.apache。 cxf.transport.ChainInitiationObserv er.onMessage（ChainInitiationObserver.java:121）
org.apache.cxf.phase.PhaseInterceptorChain.doIntercept（PhaseInterceptorChain.java:262)
org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage（ServiceInvokerInterceptor。 java：94）
org.apache.cxf.interceptor.ServiceInvokerInterceptor $ 1.run（ServiceInvokerInterceptor.java:58）
org.apache.cxf.jaxrs.JAXRSInvoker.invoke（JAXRSInvoker.java:89）
org.apache.cxf.jaxrs.JAXRSInvoker.invoke（JAXRSInvoker.java:168）
org.apache.cxf.service.invoker.AbstractInvoker.invoke（AbstractInvoker.java:96）
org .apache.cxf.service.invoker.AbstractInvoker.performInvocation（AbstractInvoker.java:180)
java.lang.reflect.Method.invoke（Method.java:498）
sun.reflect.DelegatingMethodAccessorImpl.invoke （DelegatingMethodAccessorImpl.java:43）
sun.reflect.NativeMethodAccessorImpl.invoke（NativeMethodAccessorImpl.java:62）
sun.reflect.NativeMethodAccessorImpl.invoke0（Native Method）
biz.te2.core。 services.beacon.impl.Beacon Resource.getVenuesBeaconData（BeaconResource.java:105）
xxx.xxx.xxx.getBeaconHealthForRangeAndVenue（BeaconHealthServiceImpl.java:40）
xxx.xxx.xxx..getAllMessagesCount（BeaconHealthServiceImpl.java:80）
com.sun.proxy。$ Proxy146.getMessageCountForDuration（未知来源）
org.apache.aries.proxy.impl.ProxyHandler.invoke（ProxyHandler.java:78）
org.apache.aries.proxy .impl.DefaultWrapper.invoke（DefaultWrapper.java:31）
org.apache.aries.proxy.impl.ProxyHandler $ 1.invoke（ProxyHandler.java:50）
java.lang.reflect.Method。 invoke（Method.java:498）
sun.reflect.DelegatingMethodAccessorImpl.invoke（DelegatingMethodAccessorImpl.java:43）
sun.reflect.NativeMethodAccessorImpl.invoke（NativeMethodAccessorImpl.java:62）
sun。 reflect.NativeMethodAccessorImpl.invoke0（Native Method）
xxx.xxx.xxx.getMessageCountForDuration（MessageCouchbaseRepo.java:364）
xxx.xxx.xxx.getN1qlQueryRows（MessageCouchbaseRepo.java:372）
com .couchbase.client.java.CouchbaseBucket.query（Couc hbaseBucket.java:582)
com.couchbase.client.java.CouchbaseBucket.query（CouchbaseBucket.java:656）
com.couchbase.client.java.util.Blocking.blockForSingle（Blocking.java： 74）
java.util.concurrent.CountDownLatch.await（CountDownLatch.java:277）
java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos（AbstractQueuedSynchronizer.java:1328)
java。 util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos（AbstractQueuedSynchronizer.java:1037)
java.util.concurrent.locks.LockSupport.parkNanos（LockSupport.java:215）
这是一个根据要求可以正常工作的查询示例。
public static final String EXPERIENCE_ID_STATEMENT =Select id+
from read as exp+
where id not missing+
和docType ='体验'+
和venueId = $ venueId+
和exp.rule.poiIds不是m发布+
，exp.rule.poiIds中的任何poi都满足poi = $ poiId end;
这个查询与其他查询唯一不同的是它使用 IN 子句并通过参数化的 JsonArray 接收字段。
没有网络延迟。我不认为这是一个问题，因为其他查询正在工作，它们基本上是一个接一个地链接（我还测试了单独运行此查询，它仍然执行速度非常慢）。
App和CB都在AWS上。我已经在同一台AWS服务器和不同服务器上进行了测试，在这两种情况下都存在问题。我在AWS上有一个客户端而不在AWS上，两者都有问题。通过客户端我的意思是一种调用我的应用程序的机制。调用查询时它仍然会超时。
我的collectinfo couchbase日志在这里s3.amazonaws.com/cb-customers/TE2 /
解决方案我发现它与IN子句中值的参数化有关。当我从查询中删除参数化时，我能够像CBQ一样快地运行。我唯一的选择是删除参数化。我尝试将二级索引调整一点，将 ParentMsgId 移动到字段列表的末尾，这对我的情况没有帮助。
从couchbase rep诊断出的潜在问题。
基本问题是，一旦你将IN值放在
参数中，优化器就不能假设IN子句只有一个
的值。由于experienceId引导索引，我们只能使用等于
来向下移动索引并开始计算应用
的键，因为我们必须跳过并扫描。我建议将
索引创建为（docType，publishTimestamp，ParentMsgId），这样我们就可以在
publishTimestamp上设置的条件下扫描索引，并在experienceId上应用过滤器稍后在
管道中。
Using Couchbase server 4.1.0 (and 4.5), Java SDK 2.2.8 (also tried with 2.2.7, 2.3.1, & 2.3.3), I have a query leveraging a secondary index which runs fine when I run my code locally and even via CBQ (CBQ takes about 3ms) on the AWS server. However, when running my app on AWS, I get a TimeOutException and it's only one query which is timing out, others are not. See details below.
May be worth noting my Couchbase setup has 3 buckets.
Example Doc:
"bucketName": {
"userName": "User_A",
"MessageContent": "This is a message",
"docType": "msg",
"ParentMsgId": "1234",
"MsgType": "test",
"expireTimestamp": 1454975772613,
"publishTimestamp": 1455322362028,
"id": "145826845",
"urls": [],
"subject": "this is a subject",
"type": 1,
"GroupId": "Group_1"
}
Secondary Index:
CREATE INDEX `indexName` ON `bucketName`(`ParentMsgId`,`docType`,`publishTimestamp`) USING GSI
Example Query extracted from N1qlQuery#n1ql()
{"statement":
"select count(*) as msgCount from bucketName
where ParentMsgId is not missing and docType = 'msg'
and ParentMsgId IN $parentId
and publishTimestamp between $startTime and $endTime
","$endTime":1470726861816,
"$startTime":1470640461816,
"$parenIds":["fa11845b-9ea5-4778-95fe-e7206843c69b"]
}
Java Code
public static final String COUNT_STATEMENT = "select count(*) as count " +
"from bucketName " +
"where ParentMsgId is not missing " +
"and docType = 'msg' " +
"and ParentMsgId IN $parentIds " +
"and publishTimestamp between $startTime and $endTime";
public int getCountForDuration(Long startTime, Long endTime, Collection<String> parentIds){
List<String> idList = new ArrayList<>(parentIds);
JsonObject placeHolders = JsonObject.create()
.put("parentIds", JsonArray.from(idList))
.put("startTime", startTime)
.put("endTime", endTime);
N1qlQuery query = N1qlQuery.parameterized(COUNT_STATEMENT, placeHolders)
N1qlQueryResult result = bucket.query(query);
...
}
Query Explain result
cbq> explain select count(*) as msgCount from bucketName where ParentMsgId is not missing and docType = 'msg' and ParentMsgId IN ["01b88f7f-4de6-4daa-9562-a2c902e818ad"] and publishTimestamp between 1466445409000 and 1466531809000;
{
"requestID": "61afcf02-3b3d-4c8a-aec6-b76c4c1f7b17",
"signature": "json",
"results": [
{
"#operator": "Sequence",
"~children": [
{
"#operator": "IndexScan",
"index": "indexName",
"keyspace": "bucketName",
"namespace": "default",
"spans": [
{
"Range": {
"High": [
"successor(\"01b88f7f-4de6-4daa-9562-a2c902e818ad\")"
],
"Inclusion": 1,
"Low": [
"\"01b88f7f-4de6-4daa-9562-a2c902e818ad\""
]
}
}
],
"using": "gsi"
},
{
"#operator": "Parallel",
"~child": {
"#operator": "Sequence",
"~children": [
{
"#operator": "Fetch",
"keyspace": "bucketName",
"namespace": "default"
},
{
"#operator": "Filter",
"condition": "(((((`bucketName`.`ParentMsgId`) is not missing) and ((`bucketName`.`docType`) = \"msg\")) and ((`bucketName`.`ParentMsgId`) in [\"01b88f7f-4de6-4daa-9562-a2c902e818ad\"])) and ((`bucketName`.`publishTimestamp`) between 1466445409000 and 1466531809000))"
},
{
"#operator": "InitialGroup",
"aggregates": [
"count(*)"
],
"group_keys": []
}
]
}
},
{
"#operator": "IntermediateGroup",
"aggregates": [
"count(*)"
],
"group_keys": []
},
{
"#operator": "FinalGroup",
"aggregates": [
"count(*)"
],
"group_keys": []
},
{
"#operator": "Parallel",
"~child": {
"#operator": "Sequence",
"~children": [
{
"#operator": "InitialProject",
"result_terms": [
{
"as": "msgCount",
"expr": "count(*)"
}
]
},
{
"#operator": "FinalProject"
}
]
}
}
]
}
],
"status": "success",
"metrics": {
"elapsedTime": "2.748194ms",
"executionTime": "2.660232ms",
"resultCount": 1,
"resultSize": 3274
}
}
Logs
java.lang.Thread.run(Thread.java:745)
org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:533)
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:598)
org.eclipse.jetty.server.nio.BlockingChannelConnector$BlockingChannelEndPoint.run(BlockingChannelConnector.java:293)
org.eclipse.jetty.server.BlockingHttpConnection.handle(BlockingHttpConnection.java:50)
org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:218)
org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:582)
org.eclipse.jetty.server.HttpConnection$RequestHandler.headerComplete(HttpConnection.java:919)
org.eclipse.jetty.server.HttpConnection.handleRequest(HttpConnection.java:441)
org.eclipse.jetty.server.Server.handle(Server.java:349)
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:110)
org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:149)
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:117)
org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:875)
org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:186)
org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:409)
org.ops4j.pax.web.service.jetty.internal.HttpServiceContext.doHandle(HttpServiceContext.java:117)
org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:941)
org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:227)
org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:483)
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:119)
org.ops4j.pax.web.service.jetty.internal.HttpServiceServletHandler.doHandle(HttpServiceServletHandler.java:70)
org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:480)
org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:547)
org.apache.cxf.transport.servlet.AbstractHTTPServlet.service(AbstractHTTPServlet.java:201)
javax.servlet.http.HttpServlet.service(HttpServlet.java:693)
org.apache.cxf.transport.servlet.AbstractHTTPServlet.doGet(AbstractHTTPServlet.java:150)
org.apache.cxf.transport.servlet.AbstractHTTPServlet.handleRequest(AbstractHTTPServlet.java:225)
org.apache.cxf.transport.servlet.CXFNonSpringServlet.invoke(CXFNonSpringServlet.java:130)
org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:194)
org.apache.cxf.transport.servlet.ServletController.invokeDestination(ServletController.java:214)
org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:237)
org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:121)
org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:262)
org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(ServiceInvokerInterceptor.java:94)
org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceInvokerInterceptor.java:58)
org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:89)
org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:168)
org.apache.cxf.service.invoker.AbstractInvoker.invoke(AbstractInvoker.java:96)
org.apache.cxf.service.invoker.AbstractInvoker.performInvocation(AbstractInvoker.java:180)
java.lang.reflect.Method.invoke(Method.java:498)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
biz.te2.core.services.beacon.impl.BeaconResource.getVenuesBeaconData(BeaconResource.java:105)
xxx.xxx.xxx.getBeaconHealthForRangeAndVenue(BeaconHealthServiceImpl.java:40)
xxx.xxx.xxx..getAllMessagesCount(BeaconHealthServiceImpl.java:80)
com.sun.proxy.$Proxy146.getMessageCountForDuration(Unknown Source)
org.apache.aries.proxy.impl.ProxyHandler.invoke(ProxyHandler.java:78)
org.apache.aries.proxy.impl.DefaultWrapper.invoke(DefaultWrapper.java:31)
org.apache.aries.proxy.impl.ProxyHandler$1.invoke(ProxyHandler.java:50)
java.lang.reflect.Method.invoke(Method.java:498)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
xxx.xxx.xxx.getMessageCountForDuration(MessageCouchbaseRepo.java:364)
xxx.xxx.xxx.getN1qlQueryRows(MessageCouchbaseRepo.java:372)
com.couchbase.client.java.CouchbaseBucket.query(CouchbaseBucket.java:582)
com.couchbase.client.java.CouchbaseBucket.query(CouchbaseBucket.java:656)
com.couchbase.client.java.util.Blocking.blockForSingle(Blocking.java:74)
java.util.concurrent.CountDownLatch.await(CountDownLatch.java:277)
java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328)
java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037)
java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
This is an example of a query which works fine, as requested.
public static final String EXPERIENCE_ID_STATEMENT = "Select id " +
"from read as exp " +
"where id is not missing " +
"and docType = 'experience' " +
"and venueId = $venueId " +
"and exp.rule.poiIds is not missing " +
"and any poi in exp.rule.poiIds satisfies poi = $poiId end";
The only thing unique about this query versus the others, is it uses an IN clause and receives the fields via a parameterized JsonArray.
There are no network delays. I don't think this is an issue, as other queries are working and they are essentially chained called one after another (I also tested running this query alone and it still performs extremely slow).
App and CB are both on AWS. I have tested with both on same AWS server and on different servers as well in both cases issue is there. I have a client on AWS and not on AWS, both have the issue. By a client I mean a mechanism that invokes my app. It still gets a timeout when the query is called.
My collectinfo couchbase logs are here s3.amazonaws.com/cb-customers/TE2/
解决方案 I found the issue it has to do with the parameterization of the values in the IN clause. When I removed the parameterization from the query I was able to run as fast as CBQ. My only option was to drop parameterizing.I Attempted to adjust the secondary index a bit moving the ParentMsgId to the end of the fields list this did not help in my case.
The underlying problem diagnosed from couchbase rep.
the underlying issue is that once you put the IN values in a
parameter, the optimiser can't assume the IN clause only has one
value. Since experienceId leads the index, we can only use an equality
to travel down the index and start counting the keys that apply
because we would have to skip and scan. I would suggest creating the
index as (docType, publishTimestamp, ParentMsgId), that way we can
still scan the index on the conditions set on docType,
publishTimestamp, and apply the filter on experienceId later on in the
pipeline.
这篇关于使用参数化IN子句时，N1QL查询超时的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
查看全文
