Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
Shardingsphere
提交
0b3f8f2a
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 搜索 >>
提交
0b3f8f2a
编写于
10月 26, 2018
作者:
C
cherrylzhao
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
#1363 Add init DBCP Converter implement.
上级
9f007850
变更
4
隐藏空白更改
内联
并排
Showing
4 changed file
with
52 addition
and
14 deletion
+52
-14
sharding-transaction/src/main/java/io/shardingsphere/transaction/manager/xa/XABackendDataSourceConvert.java
...re/transaction/manager/xa/XABackendDataSourceConvert.java
+5
-8
sharding-transaction/src/main/java/io/shardingsphere/transaction/manager/xa/XATransactionManager.java
...ngsphere/transaction/manager/xa/XATransactionManager.java
+1
-2
sharding-transaction/src/main/java/io/shardingsphere/transaction/manager/xa/convert/DBCPConverter.java
...gsphere/transaction/manager/xa/convert/DBCPConverter.java
+35
-0
sharding-transaction/src/main/java/io/shardingsphere/transaction/manager/xa/convert/DataSourceParameterFactory.java
...action/manager/xa/convert/DataSourceParameterFactory.java
+11
-4
未找到文件。
sharding-transaction/src/main/java/io/shardingsphere/transaction/manager/xa/XABackendDataSourceConvert.java
浏览文件 @
0b3f8f2a
...
...
@@ -21,9 +21,9 @@ import io.shardingsphere.core.constant.DatabaseType;
import
io.shardingsphere.core.constant.transaction.TransactionType
;
import
io.shardingsphere.spi.xa.BackendDataSourceFactory
;
import
io.shardingsphere.transaction.manager.ShardingTransactionManagerRegistry
;
import
io.shardingsphere.transaction.manager.xa.convert.DataSourceParameterFactory
;
import
javax.sql.DataSource
;
import
javax.sql.XADataSource
;
import
java.util.HashMap
;
import
java.util.Map
;
...
...
@@ -32,15 +32,12 @@ public final class XABackendDataSourceConvert implements BackendDataSourceFactor
private
static
XATransactionManager
XA_MANAGER
=
(
XATransactionManager
)
ShardingTransactionManagerRegistry
.
getInstance
().
getShardingTransactionManager
(
TransactionType
.
XA
);
@Override
public
Map
<
String
,
DataSource
>
build
(
final
Map
<
String
,
DataSource
>
dataSourceMap
,
DatabaseType
databaseType
)
{
public
Map
<
String
,
DataSource
>
build
(
final
Map
<
String
,
DataSource
>
dataSourceMap
,
final
DatabaseType
databaseType
)
{
Map
<
String
,
DataSource
>
result
=
new
HashMap
<>(
dataSourceMap
.
size
(),
1
);
for
(
Map
.
Entry
<
String
,
DataSource
>
entry
:
dataSourceMap
.
entrySet
())
{
// result.put(entry.getKey(), TM_MANAGER.wrapDataSource())
DataSource
dataSource
=
XA_MANAGER
.
wrapDataSource
(
XADatasourceFactory
.
build
(
databaseType
),
entry
.
getKey
(),
DataSourceParameterFactory
.
build
(
entry
.
getValue
()));
result
.
put
(
entry
.
getKey
(),
dataSource
);
}
return
null
;
}
private
XADataSource
newXADataSource
(
DatabaseType
databaseType
)
{
return
null
;
return
result
;
}
}
sharding-transaction/src/main/java/io/shardingsphere/transaction/manager/xa/XATransactionManager.java
浏览文件 @
0b3f8f2a
...
...
@@ -44,7 +44,6 @@ public interface XATransactionManager extends ShardingTransactionManager<XATrans
* @param dataSourceName data source name
* @param dataSourceParameter data source parameter
* @return XA data source
* @throws Exception if can not wrap the data source
*/
DataSource
wrapDataSource
(
XADataSource
xaDataSource
,
String
dataSourceName
,
DataSourceParameter
dataSourceParameter
)
throws
Exception
;
DataSource
wrapDataSource
(
XADataSource
xaDataSource
,
String
dataSourceName
,
DataSourceParameter
dataSourceParameter
);
}
sharding-transaction/src/main/java/io/shardingsphere/transaction/manager/xa/convert/DBCPConverter.java
0 → 100644
浏览文件 @
0b3f8f2a
/*
* Copyright 2016-2018 shardingsphere.io.
* <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.shardingsphere.transaction.manager.xa.convert
;
import
io.shardingsphere.core.rule.DataSourceParameter
;
import
javax.sql.DataSource
;
/**
* Convert implement of Commons DBCP.
*
* @author zhaojun
*/
public
final
class
DBCPConverter
implements
Convertor
{
@Override
public
DataSourceParameter
convertTo
(
DataSource
dataSource
)
{
return
null
;
}
}
sharding-transaction/src/main/java/io/shardingsphere/transaction/manager/xa/convert/DataSourceParameterFactory.java
浏览文件 @
0b3f8f2a
...
...
@@ -19,6 +19,8 @@ package io.shardingsphere.transaction.manager.xa.convert;
import
io.shardingsphere.core.rule.DataSourceParameter
;
import
javax.sql.DataSource
;
/**
* Get property of common datasource pool then convert to {@code DataSourceParameter}.
*
...
...
@@ -29,16 +31,21 @@ public class DataSourceParameterFactory {
/**
* Create datasource parameter.
*
* @param
poolType pool typ
e
* @param
dataSource data sourc
e
* @return datasource parameter
*/
public
static
DataSourceParameter
build
(
final
PoolType
poolType
)
{
switch
(
poolType
)
{
public
static
DataSourceParameter
build
(
final
DataSource
dataSource
)
{
switch
(
getPoolType
(
dataSource
))
{
case
HIKARI:
case
DRUID:
case
DBCP:
return
new
DBCPConverter
().
convertTo
(
dataSource
);
default
:
return
null
;
}
}
private
static
PoolType
getPoolType
(
final
DataSource
dataSource
)
{
return
null
;
}
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录