Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
Shardingsphere
提交
560a8e00
Shardingsphere
项目概览
apache
/
Shardingsphere
通知
56
Star
3
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
Shardingsphere
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
560a8e00
编写于
3月 19, 2018
作者:
T
terrymanu
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
add ShardingRuleException
上级
de9e1200
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
42 addition
and
5 deletion
+42
-5
sharding-jdbc-core/src/main/java/io/shardingjdbc/core/rule/ShardingRule.java
...src/main/java/io/shardingjdbc/core/rule/ShardingRule.java
+4
-5
sharding-jdbc-core/src/main/java/io/shardingjdbc/core/rule/ShardingRuleException.java
...java/io/shardingjdbc/core/rule/ShardingRuleException.java
+38
-0
未找到文件。
sharding-jdbc-core/src/main/java/io/shardingjdbc/core/rule/ShardingRule.java
浏览文件 @
560a8e00
...
...
@@ -19,7 +19,6 @@ package io.shardingjdbc.core.rule;
import
com.google.common.base.Optional
;
import
com.google.common.base.Strings
;
import
io.shardingjdbc.core.exception.ShardingJdbcException
;
import
io.shardingjdbc.core.keygen.KeyGenerator
;
import
io.shardingjdbc.core.parsing.parser.context.condition.Column
;
import
io.shardingjdbc.core.routing.strategy.ShardingStrategy
;
...
...
@@ -130,7 +129,7 @@ public final class ShardingRule {
if
(
null
!=
defaultDataSourceName
)
{
return
createTableRuleWithDefaultDataSource
(
logicTableName
.
toLowerCase
());
}
throw
new
Sharding
Jdbc
Exception
(
"Cannot find table rule and default data source with logic table: '%s'"
,
logicTableName
);
throw
new
Sharding
Rule
Exception
(
"Cannot find table rule and default data source with logic table: '%s'"
,
logicTableName
);
}
private
TableRule
createTableRuleWithDefaultDataSource
(
final
String
logicTableName
)
{
...
...
@@ -274,7 +273,7 @@ public final class ShardingRule {
public
Number
generateKey
(
final
String
logicTableName
)
{
Optional
<
TableRule
>
tableRule
=
tryFindTableRuleByLogicTable
(
logicTableName
);
if
(!
tableRule
.
isPresent
())
{
throw
new
Sharding
Jdbc
Exception
(
"Cannot find strategy for generate keys."
);
throw
new
Sharding
Rule
Exception
(
"Cannot find strategy for generate keys."
);
}
if
(
null
!=
tableRule
.
get
().
getKeyGenerator
())
{
return
tableRule
.
get
().
getKeyGenerator
().
generateKey
();
...
...
@@ -294,7 +293,7 @@ public final class ShardingRule {
return
each
.
getLogicTable
();
}
}
throw
new
Sharding
Jdbc
Exception
(
"Cannot find logic table name with logic index name: '%s'"
,
logicIndexName
);
throw
new
Sharding
Rule
Exception
(
"Cannot find logic table name with logic index name: '%s'"
,
logicIndexName
);
}
/**
...
...
@@ -310,6 +309,6 @@ public final class ShardingRule {
return
each
;
}
}
throw
new
Sharding
Jdbc
Exception
(
"Cannot find actual data node for logic table name: '%s'"
,
tableRule
.
getLogicTable
());
throw
new
Sharding
Rule
Exception
(
"Cannot find actual data node for logic table name: '%s'"
,
tableRule
.
getLogicTable
());
}
}
sharding-jdbc-core/src/main/java/io/shardingjdbc/core/rule/ShardingRuleException.java
0 → 100644
浏览文件 @
560a8e00
/*
* Copyright 1999-2015 dangdang.com.
* <p>
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* </p>
*/
package
io.shardingjdbc.core.rule
;
/**
* Sharding rule exception.
*
* @author zhangliang
*/
public
final
class
ShardingRuleException
extends
RuntimeException
{
private
static
final
long
serialVersionUID
=
-
1360264079938958332L
;
/**
* Constructs an exception with formatted error message and arguments.
*
* @param errorMessage formatted error message
* @param args arguments of error message
*/
public
ShardingRuleException
(
final
String
errorMessage
,
final
Object
...
args
)
{
super
(
String
.
format
(
errorMessage
,
args
));
}
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录