Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
Shardingsphere
提交
aaa234b2
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,体验更适合开发者的 AI 搜索 >>
提交
aaa234b2
编写于
8月 11, 2017
作者:
T
terrymanu
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
for checkstyle
上级
a56ed94f
变更
8
隐藏空白更改
内联
并排
Showing
8 changed file
with
42 addition
and
17 deletion
+42
-17
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/context/OrderItem.java
...dframe/rdb/sharding/parsing/parser/context/OrderItem.java
+1
-2
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/mysql/MySQLSelectParser.java
...rding/parsing/parser/dialect/mysql/MySQLSelectParser.java
+8
-3
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/oracle/OracleSelectParser.java
...ing/parsing/parser/dialect/oracle/OracleSelectParser.java
+8
-3
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/postgresql/PostgreSQLSelectParser.java
...ing/parser/dialect/postgresql/PostgreSQLSelectParser.java
+7
-6
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/sqlserver/SQLServerSelectParser.java
...rsing/parser/dialect/sqlserver/SQLServerSelectParser.java
+7
-2
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/statement/ddl/DDLStatement.java
...b/sharding/parsing/parser/statement/ddl/DDLStatement.java
+1
-1
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/statement/dql/select/AbstractSelectParser.java
...ing/parser/statement/dql/select/AbstractSelectParser.java
+5
-0
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/token/SQLToken.java
...g/ddframe/rdb/sharding/parsing/parser/token/SQLToken.java
+5
-0
未找到文件。
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/context/OrderItem.java
浏览文件 @
aaa234b2
...
...
@@ -30,6 +30,7 @@ import lombok.ToString;
* @author zhangliang
*/
@Getter
@Setter
@EqualsAndHashCode
@ToString
public
final
class
OrderItem
{
...
...
@@ -40,10 +41,8 @@ public final class OrderItem {
private
final
OrderType
type
;
@Setter
private
int
index
=
-
1
;
@Setter
private
Optional
<
String
>
alias
;
public
OrderItem
(
final
String
name
,
final
OrderType
type
,
final
Optional
<
String
>
alias
)
{
...
...
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/mysql/MySQLSelectParser.java
浏览文件 @
aaa234b2
...
...
@@ -35,7 +35,12 @@ import com.dangdang.ddframe.rdb.sharding.parsing.parser.token.RowCountToken;
import
java.util.Collection
;
import
java.util.Collections
;
public
class
MySQLSelectParser
extends
AbstractSelectParser
{
/**
* MySQL Select语句解析器.
*
* @author zhangliang
*/
public
final
class
MySQLSelectParser
extends
AbstractSelectParser
{
public
MySQLSelectParser
(
final
AbstractSQLParser
sqlParser
)
{
super
(
sqlParser
);
...
...
@@ -47,13 +52,13 @@ public class MySQLSelectParser extends AbstractSelectParser {
}
@Override
protected
final
void
parseBeforeSelectList
()
{
protected
void
parseBeforeSelectList
()
{
getSqlParser
().
skipAll
(
MySQLKeyword
.
HIGH_PRIORITY
,
DefaultKeyword
.
STRAIGHT_JOIN
,
MySQLKeyword
.
SQL_SMALL_RESULT
,
MySQLKeyword
.
SQL_BIG_RESULT
,
MySQLKeyword
.
SQL_BUFFER_RESULT
,
MySQLKeyword
.
SQL_CACHE
,
MySQLKeyword
.
SQL_NO_CACHE
,
MySQLKeyword
.
SQL_CALC_FOUND_ROWS
);
}
@Override
protected
final
void
customizedSelect
()
{
protected
void
customizedSelect
()
{
parseLimit
();
if
(
getSqlParser
().
equalAny
(
DefaultKeyword
.
PROCEDURE
))
{
throw
new
SQLParsingUnsupportedException
(
getSqlParser
().
getLexer
().
getCurrentToken
().
getType
());
...
...
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/oracle/OracleSelectParser.java
浏览文件 @
aaa234b2
...
...
@@ -29,7 +29,12 @@ import com.dangdang.ddframe.rdb.sharding.parsing.parser.statement.dql.select.Abs
import
java.util.Collection
;
import
java.util.Collections
;
public
class
OracleSelectParser
extends
AbstractSelectParser
{
/**
* Oracle Select语句解析器.
*
* @author zhangliang
*/
public
final
class
OracleSelectParser
extends
AbstractSelectParser
{
public
OracleSelectParser
(
final
AbstractSQLParser
sqlParser
)
{
super
(
sqlParser
);
...
...
@@ -41,7 +46,7 @@ public class OracleSelectParser extends AbstractSelectParser {
}
@Override
protected
final
void
customizedBetweenWhereAndGroupBy
()
{
protected
void
customizedBetweenWhereAndGroupBy
()
{
skipHierarchicalQueryClause
();
}
...
...
@@ -70,7 +75,7 @@ public class OracleSelectParser extends AbstractSelectParser {
}
@Override
protected
final
void
customizedBetweenGroupByAndOrderBy
()
{
protected
void
customizedBetweenGroupByAndOrderBy
()
{
skipModelClause
();
}
...
...
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/postgresql/PostgreSQLSelectParser.java
浏览文件 @
aaa234b2
...
...
@@ -32,14 +32,19 @@ import com.dangdang.ddframe.rdb.sharding.parsing.parser.token.RowCountToken;
import
com.dangdang.ddframe.rdb.sharding.util.NumberUtil
;
import
com.google.common.base.Optional
;
public
class
PostgreSQLSelectParser
extends
AbstractSelectParser
{
/**
* PostgreSQL Select语句解析器.
*
* @author zhangliang
*/
public
final
class
PostgreSQLSelectParser
extends
AbstractSelectParser
{
public
PostgreSQLSelectParser
(
final
AbstractSQLParser
sqlParser
)
{
super
(
sqlParser
);
}
@Override
protected
final
void
customizedSelect
()
{
protected
void
customizedSelect
()
{
if
(
getSqlParser
().
equalAny
(
PostgreSQLKeyword
.
WINDOW
))
{
throw
new
SQLParsingUnsupportedException
(
PostgreSQLKeyword
.
WINDOW
);
}
...
...
@@ -127,8 +132,4 @@ public class PostgreSQLSelectParser extends AbstractSelectParser {
}
getSelectStatement
().
setLimit
(
limit
);
}
protected
boolean
hasDistinctOn
()
{
return
true
;
}
}
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/dialect/sqlserver/SQLServerSelectParser.java
浏览文件 @
aaa234b2
...
...
@@ -35,7 +35,12 @@ import com.dangdang.ddframe.rdb.sharding.parsing.parser.statement.dql.select.Abs
import
com.dangdang.ddframe.rdb.sharding.parsing.parser.token.RowCountToken
;
import
com.google.common.base.Optional
;
public
class
SQLServerSelectParser
extends
AbstractSelectParser
{
/**
* SQLServer Select语句解析器.
*
* @author zhangliang
*/
public
final
class
SQLServerSelectParser
extends
AbstractSelectParser
{
public
SQLServerSelectParser
(
final
AbstractSQLParser
sqlParser
)
{
super
(
sqlParser
);
...
...
@@ -112,7 +117,7 @@ public class SQLServerSelectParser extends AbstractSelectParser {
}
@Override
protected
final
void
customizedSelect
()
{
protected
void
customizedSelect
()
{
if
(
getSqlParser
().
equalAny
(
DefaultKeyword
.
FOR
))
{
parseFor
();
}
...
...
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/statement/ddl/DDLStatement.java
浏览文件 @
aaa234b2
...
...
@@ -31,7 +31,7 @@ import lombok.ToString;
@Getter
@Setter
@ToString
(
callSuper
=
true
)
public
class
DDLStatement
extends
AbstractSQLStatement
{
public
final
class
DDLStatement
extends
AbstractSQLStatement
{
public
DDLStatement
()
{
super
(
SQLType
.
DDL
);
...
...
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/statement/dql/select/AbstractSelectParser.java
浏览文件 @
aaa234b2
...
...
@@ -54,6 +54,11 @@ import java.util.Collections;
import
java.util.LinkedList
;
import
java.util.List
;
/**
* Select语句解析器.
*
* @author zhangliang
*/
@Getter
(
AccessLevel
.
PROTECTED
)
public
abstract
class
AbstractSelectParser
implements
SQLStatementParser
{
...
...
sharding-jdbc-core/src/main/java/com/dangdang/ddframe/rdb/sharding/parsing/parser/token/SQLToken.java
浏览文件 @
aaa234b2
...
...
@@ -24,5 +24,10 @@ package com.dangdang.ddframe.rdb.sharding.parsing.parser.token;
*/
public
interface
SQLToken
{
/**
* 获取开始位置.
*
* @return 开始位置
*/
int
getBeginPosition
();
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录