本文整理汇总了Java中net.ttddyy.dsproxy.QueryInfo类的典型用法代码示例。如果您正苦于以下问题：Java QueryInfo类的具体用法？Java QueryInfo怎么用？Java QueryInfo使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
QueryInfo类属于net.ttddyy.dsproxy包，在下文中一共展示了QueryInfo类的11个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: shouldBuildIssue
import net.ttddyy.dsproxy.QueryInfo; //导入依赖的package包/类
@Test
public void shouldBuildIssue() {
ExecutionInfo executionInfo = new ExecutionInfo();
executionInfo.setDataSourceName("ds");
QueryContext queryContext = new QueryContext(executionInfo, asList(new QueryInfo("q")));
Issue issue = issueBuilder.builder()
.type("t")
.query(queryContext)
.description("d")
.weight(0)
.metadata("m1", "v1")
.build();
assertThat(issue.getType()).isEqualTo("t");
assertThat(issue.getQuery()).isEqualTo("q");
assertThat(issue.getDataSourceName()).isEqualTo("ds");
assertThat(issue.getDescription()).isEqualTo("d");
assertThat(issue.getMetadata()).containsKey("m1");
assertThat(issue.getWeight()).isEqualTo(0);
assertThat(issue.getTimestamp()).isNotNull();
assertThat(issue.getStackTrace()).isNotEmpty();
}
开发者ID:EmbedITCZ，项目名称:dbadvisor，代码行数:24，代码来源:IssueBuilderIT.java
示例2: afterQuery
import net.ttddyy.dsproxy.QueryInfo; //导入依赖的package包/类
@Override
public void afterQuery(ExecutionInfo execInfo, List<QueryInfo> queryInfoList) {
Span span = tracer.getCurrentSpan();
if (execInfo.getThrowable() != null) {
span.tag(Span.SPAN_ERROR_TAG_NAME, ExceptionUtils.getExceptionMessage(execInfo.getThrowable()));
}
if (execInfo.getMethod().getName().equals("executeUpdate")) {
span.tag(SleuthListenerAutoConfiguration.SPAN_ROW_COUNT_TAG_NAME, String.valueOf(execInfo.getResult()));
}
tracer.close(span);
}
开发者ID:gavlyukovskiy，项目名称:spring-boot-data-source-decorator，代码行数:12，代码来源:TracingQueryExecutionListener.java
示例3: resolveQuery
import net.ttddyy.dsproxy.QueryInfo; //导入依赖的package包/类
public final String resolveQuery() {
String query = null;
if (!queryInfoList.isEmpty()) {
QueryInfo queryInfo = queryInfoList.get(0);
query = queryInfo.getQuery();
}
return query;
}
开发者ID:EmbedITCZ，项目名称:dbadvisor，代码行数:9，代码来源:QueryContext.java
示例4: afterQuery
import net.ttddyy.dsproxy.QueryInfo; //导入依赖的package包/类
@Override
public void afterQuery(ExecutionInfo execInfo, List<QueryInfo> queryInfoList) {
QueryContext ctx = new QueryContext(execInfo, queryInfoList);
String query = ctx.resolveQuery();
if (query != null && query.startsWith("select ")) {
analyzeQuery(ctx);
}
}
开发者ID:EmbedITCZ，项目名称:dbadvisor，代码行数:9，代码来源:DbAdvisorQueryExecutionListener.java
示例5: writeParamsEntry
import net.ttddyy.dsproxy.QueryInfo; //导入依赖的package包/类
@Override
protected void writeParamsEntry(StringBuilder sb, ExecutionInfo execInfo, List<QueryInfo> queryInfoList) {
sb.append("Params:[");
for (QueryInfo queryInfo : queryInfoList) {
boolean firstArg = true;
for (Map<String, Object> paramMap : queryInfo.getQueryArgsList()) {
if (!firstArg) {
sb.append(", ");
} else {
firstArg = false;
}
SortedMap<String, Object> sortedParamMap = new TreeMap<>(new StringAsIntegerComparator());
sortedParamMap.putAll(paramMap);
sb.append("(");
boolean firstParam = true;
for (Map.Entry<String, Object> paramEntry : sortedParamMap.entrySet()) {
if (!firstParam) {
sb.append(", ");
} else {
firstParam = false;
}
Object parameter = paramEntry.getValue();
if (parameter != null && parameter.getClass().isArray()) {
sb.append(arrayToString(parameter));
} else {
sb.append(parameter);
}
}
sb.append(")");
}
}
sb.append("]");
}
开发者ID:vladmihalcea，项目名称:hibernate-types，代码行数:37，代码来源:InlineQueryLogEntryCreator.java
示例6: writeQueriesEntry
import net.ttddyy.dsproxy.QueryInfo; //导入依赖的package包/类
@Override
protected void writeQueriesEntry(StringBuilder sb, ExecutionInfo execInfo, List<QueryInfo> queryInfoList) {
sb.append(System.getProperty("line.separator", "\n"));
sb.append("Query:[");
for (QueryInfo queryInfo : queryInfoList) {
String query = queryInfo.getQuery();
for (Formatter formatter : formatters) {
// .replace("\uFEFF", "")
query = formatter.format(query).replace("?", "%s");
}
List<String> params = new ArrayList<>();
for (Map<String, Object> paramMap : queryInfo.getQueryArgsList()) {
SortedMap<String, Object> sortedParamMap = new TreeMap<>(new StringAsIntegerComparator());
sortedParamMap.putAll(paramMap);
params.addAll(Lists.transform(new ArrayList<>(sortedParamMap.values()), from -> {
if (from instanceof String) {
String value = (String) from;
return value.contains("NULL") ? null : String.format(format, value);
}
else if (from instanceof Date) {
return String.format(format, dateFormat.format(from));
}
else if (from instanceof Boolean) {
return (Boolean) from ? "1" : "0";
}
else {
return String.valueOf(from);
}
}));
}
sb.append(String.format(query, params.toArray()));
sb.append(",");
}
chompIfEndWith(sb, ',');
sb.append(System.getProperty("line.separator", "\n"));
sb.append("]");
}
开发者ID:przodownikR1，项目名称:springJpaKata，代码行数:39，代码来源:ProxyDsConfig.java
示例7: writeParamsEntry
import net.ttddyy.dsproxy.QueryInfo; //导入依赖的package包/类
@Override
protected void writeParamsEntry(StringBuilder sb, ExecutionInfo execInfo, List<QueryInfo> queryInfoList) {
sb.append( "Params:[" );
for ( QueryInfo queryInfo : queryInfoList ) {
boolean firstArg = true;
for ( Map<String, Object> paramMap : queryInfo.getQueryArgsList() ) {
if ( !firstArg ) {
sb.append( ", " );
}
else {
firstArg = false;
}
SortedMap<String, Object> sortedParamMap = new TreeMap<>( new StringAsIntegerComparator() );
sortedParamMap.putAll( paramMap );
sb.append( "(" );
boolean firstParam = true;
for ( Map.Entry<String, Object> paramEntry : sortedParamMap.entrySet() ) {
if ( !firstParam ) {
sb.append( ", " );
}
else {
firstParam = false;
}
Object parameter = paramEntry.getValue();
if ( parameter != null && parameter.getClass().isArray() ) {
sb.append( arrayToString( parameter ) );
}
else {
sb.append( parameter );
}
}
sb.append( ")" );
}
}
sb.append( "]" );
}
开发者ID:vladmihalcea，项目名称:high-performance-java-persistence，代码行数:40，代码来源:InlineQueryLogEntryCreator.java
示例8: writeParamsEntry
import net.ttddyy.dsproxy.QueryInfo; //导入依赖的package包/类
@Override
protected void writeParamsEntry(StringBuilder sb, ExecutionInfo execInfo, List<QueryInfo> queryInfoList) {
sb.append("Params:[");
for (QueryInfo queryInfo : queryInfoList) {
boolean firstArg = true;
for (Map<String, Object> paramMap : queryInfo.getQueryArgsList()) {
if(!firstArg) {
sb.append(", ");
} else {
firstArg = false;
}
SortedMap<String, Object> sortedParamMap = new TreeMap<>( new StringAsIntegerComparator());
sortedParamMap.putAll(paramMap);
sb.append("(");
boolean firstParam = true;
for (Map.Entry<String, Object> paramEntry : sortedParamMap.entrySet()) {
if(!firstParam) {
sb.append(", ");
} else {
firstParam = false;
}
Object parameter = paramEntry.getValue();
if(parameter != null && parameter.getClass().isArray()) {
sb.append(arrayToString(parameter));
} else {
sb.append(parameter);
}
}
sb.append(")");
}
}
sb.append("]");
}
开发者ID:vladmihalcea，项目名称:hibernate-master-class，代码行数:37，代码来源:AbstractTest.java
示例9: beforeQuery
import net.ttddyy.dsproxy.QueryInfo; //导入依赖的package包/类
@Override
public void beforeQuery(ExecutionInfo execInfo, List<QueryInfo> queryInfoList) {
Span span = tracer.createSpan("jdbc:/" + execInfo.getDataSourceName() + SleuthListenerAutoConfiguration.SPAN_QUERY_POSTFIX);
span.tag(SleuthListenerAutoConfiguration.SPAN_SQL_QUERY_TAG_NAME, queryInfoList.stream().map(QueryInfo::getQuery).collect(Collectors.joining("\n")));
span.tag(Span.SPAN_LOCAL_COMPONENT_TAG_NAME, "database");
}
开发者ID:gavlyukovskiy，项目名称:spring-boot-data-source-decorator，代码行数:7，代码来源:TracingQueryExecutionListener.java
示例10: beforeQuery
import net.ttddyy.dsproxy.QueryInfo; //导入依赖的package包/类
@Override
public void beforeQuery(ExecutionInfo execInfo, List<QueryInfo> queryInfoList) {
// noop
}
开发者ID:EmbedITCZ，项目名称:dbadvisor，代码行数:5，代码来源:DbAdvisorQueryExecutionListener.java
示例11: writeParamsEntry
import net.ttddyy.dsproxy.QueryInfo; //导入依赖的package包/类
@Override
protected void writeParamsEntry(StringBuilder sb, ExecutionInfo execInfo, List<QueryInfo> queryInfoList) {
}
开发者ID:przodownikR1，项目名称:springJpaKata，代码行数:4，代码来源:ProxyDsConfig.java
注：本文中的net.ttddyy.dsproxy.QueryInfo类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论