2.2.0版本源码下载2.2

nacos-datasource-plugin模块修改重点2.4.1

com.alibaba.nacos.plugin.datasource.mapper.Mapper修改2.5

nacos-console模块修改2.6

Nacos2.2.0适配Oracle12C-建表ddl语句2.7

打包总结一、Nacos官方文档

dependencygroupIdcom.oracle.ojdbc/groupIdartifactIdojdbc8/artifactIdversion${ojdbc.version}/version/dependency2.2.2

nacos-config

dependencygroupIdcom.oracle.ojdbc/groupIdartifactIdojdbc8/artifactId/dependency2.3

nacos-config模块修改

修改类config/src/main/java/com/alibaba/nacos/config/server/service/datasource/ExternalDataSourceProperties.java

/**

http://www.apache.org/licenses/LICENSE-2.0**

Unless

com.alibaba.nacos.config.server.service.datasource;import

com.alibaba.nacos.common.utils.Preconditions;

import

com.alibaba.nacos.common.utils.StringUtils;

import

com.zaxxer.hikari.HikariDataSource;

import

org.apache.commons.collections.CollectionUtils;

import

org.springframework.boot.context.properties.bind.Bindable;

import

org.springframework.boot.context.properties.bind.Binder;

import

org.springframework.core.env.Environment;import

java.util.ArrayList;

com.alibaba.nacos.common.utils.CollectionUtils.getOrDefault;/***

Properties

(StringUtils.isBlank(testQuery))

{this.testQuery

(StringUtils.isBlank(jdbcDriverName))

{this.jdbcDriverName

HikariDataSource}*/ListHikariDataSource

build(Environment

ArrayList();Binder.get(environment).bind(db,

Bindable.ofInstance(this));Preconditions.checkArgument(Objects.nonNull(num),

db.num

null);Preconditions.checkArgument(CollectionUtils.isNotEmpty(user),

db.user

null);Preconditions.checkArgument(CollectionUtils.isNotEmpty(password),

db.password

1;Preconditions.checkArgument(url.size()

currentSize,

index);DataSourcePoolProperties

poolProperties

DataSourcePoolProperties.build(environment);if

(StringUtils.isEmpty(poolProperties.getDataSource().getDriverClassName()))

{poolProperties.setDriverClassName(jdbcDriverName);}poolProperties.setJdbcUrl(url.get(index).trim());poolProperties.setUsername(getOrDefault(user,

index,

user.get(0)).trim());poolProperties.setPassword(getOrDefault(password,

index,

password.get(0)).trim());HikariDataSource

poolProperties.getDataSource();if

(StringUtils.isEmpty(ds.getConnectionTestQuery()))

{ds.setConnectionTestQuery(testQuery);}dataSources.add(ds);callback.accept(ds);}Preconditions.checkArgument(CollectionUtils.isNotEmpty(dataSources),

datasource

修改类plugin/datasource/src/main/java/com/alibaba/nacos/plugin/datasource/constants/DataSourceConstant.java

/**

http://www.apache.org/licenses/LICENSE-2.0**

Unless

com.alibaba.nacos.plugin.datasource.constants;/***

The

在plugin/datasource/src/main/java/com/alibaba/nacos/plugin/datasource/impl/再在oracle目录新增实现类各个类代码如下

/**

http://www.apache.org/licenses/LICENSE-2.0**

Unless

com.alibaba.nacos.plugin.datasource.impl.oracle;import

com.alibaba.nacos.plugin.datasource.constants.DataSourceConstant;

import

com.alibaba.nacos.plugin.datasource.constants.TableConstant;

import

com.alibaba.nacos.plugin.datasource.mapper.AbstractMapper;

import

com.alibaba.nacos.plugin.datasource.mapper.ConfigInfoAggrMapper;import

java.util.List;/***

{datumString.append(\).append(datum).append(,);}datumString.deleteCharAt(datumString.length()

1);return

);}sql.append(?);}sql.append());return

String

data_id,group_id,tenant_id,datum_id,app_name,content

FROM

findConfigInfoAggrByPageFetchRows(int

startRow,

data_id,group_id,tenant_id,datum_id,app_name,content,

ROWNUM

config_info_aggr;}Overridepublic

String

TableConstant.CONFIG_INFO_AGGR;}Overridepublic

String

http://www.apache.org/licenses/LICENSE-2.0**

Unless

com.alibaba.nacos.plugin.datasource.impl.oracle;import

com.alibaba.nacos.plugin.datasource.constants.DataSourceConstant;

import

com.alibaba.nacos.plugin.datasource.constants.TableConstant;

import

com.alibaba.nacos.plugin.datasource.mapper.AbstractMapper;

import

com.alibaba.nacos.plugin.datasource.mapper.ConfigInfoBetaMapper;/***

The

findAllConfigInfoBetaForDumpAllFetchRows(int

startRow,

t.id,data_id,group_id,tenant_id,app_name,content,md5,gmt_modified,beta_ips,encrypted_data_key

FROM

TableConstant.CONFIG_INFO_BETA;}Overridepublic

String

http://www.apache.org/licenses/LICENSE-2.0**

Unless

com.alibaba.nacos.plugin.datasource.impl.oracle;import

com.alibaba.nacos.common.utils.CollectionUtils;

import

com.alibaba.nacos.common.utils.StringUtils;

import

com.alibaba.nacos.plugin.datasource.constants.DataSourceConstant;

import

com.alibaba.nacos.plugin.datasource.constants.TableConstant;

import

com.alibaba.nacos.plugin.datasource.mapper.AbstractMapper;

import

com.alibaba.nacos.plugin.datasource.mapper.ConfigInfoMapper;import

java.sql.Timestamp;

findConfigInfoByAppFetchRows(int

startRow,

id,data_id,group_id,tenant_id,app_name,content,

ROWNUM

findAllConfigInfoBaseFetchRows(int

startRow,

t.id,data_id,group_id,content,md5

FROM

id,data_id,group_id,tenant_id,app_name,content,md5,gmt_modified,type,encrypted_data_key

FROM

gmt_modified,encrypted_data_key

FROM

findChangeConfigCountRows(MapString,

String

(!StringUtils.isBlank(tenantTmp))

{where

(!StringUtils.isBlank(appName))

{where

findChangeConfigFetchRows(MapString,

String

id,data_id,group_id,tenant_id,app_name,content,type,md5,gmt_modified

ROWNUM

(!StringUtils.isBlank(tenantTmp))

{where

(!StringUtils.isBlank(appName))

{where

listGroupKeyMd5ByPageFetchRows(int

startRow,

t.id,data_id,group_id,tenant_id,app_name,md5,type,gmt_modified,encrypted_data_key

FROM

findAllConfigInfo4Export(ListLong

ids,

id,data_id,group_id,tenant_id,app_name,content,type,md5,gmt_create,gmt_modified,src_user,src_ip,

c_desc,c_use,effect,c_schema,encrypted_data_key

FROM

(!CollectionUtils.isEmpty(ids))

{where.append(

);}where.append(?);paramList.add(ids.get(i));}where.append()

);}

(!StringUtils.isBlank(params.get(DATA_ID)))

{where.append(

(StringUtils.isNotBlank(params.get(GROUP)))

{where.append(

(StringUtils.isNotBlank(params.get(APP_NAME)))

{where.append(

findConfigInfoBaseLikeCountRows(MapString,

String

(!StringUtils.isBlank(params.get(DATA_ID)))

{where

(!StringUtils.isBlank(params.get(GROUP)))

{where

(!StringUtils.isBlank(params.get(CONTENT)))

{where

findConfigInfoBaseLikeFetchRows(MapString,

String

id,data_id,group_id,tenant_id,content,

ROWNUM

(!StringUtils.isBlank(params.get(DATA_ID)))

{where

(!StringUtils.isBlank(params.get(GROUP)))

{where

(!StringUtils.isBlank(params.get(CONTENT)))

{where

findConfigInfo4PageCountRows(MapString,

String

(StringUtils.isNotBlank(dataId))

{where.append(

(StringUtils.isNotBlank(group))

{where.append(

(StringUtils.isNotBlank(appName))

{where.append(

findConfigInfo4PageFetchRows(MapString,

String

id,data_id,group_id,tenant_id,app_name,content,type,encrypted_data_key,

ROWNUM

(StringUtils.isNotBlank(dataId))

{where.append(

(StringUtils.isNotBlank(group))

{where.append(

(StringUtils.isNotBlank(appName))

{where.append(

findConfigInfoBaseByGroupFetchRows(int

startRow,

findConfigInfoLike4PageCountRows(MapString,

String

(!StringUtils.isBlank(appName))

{where.append(

(!StringUtils.isBlank(content))

{where.append(

findConfigInfoLike4PageFetchRows(MapString,

String

id,data_id,group_id,tenant_id,app_name,content,encrypted_data_key,

ROWNUM

(!StringUtils.isBlank(appName))

{where.append(

(!StringUtils.isBlank(content))

{where.append(

t.id,data_id,group_id,tenant_id,app_name,content,md5

FROM

ID,data_id,group_id,tenant_id,app_name,content,md5

FROM

removeConfigInfoByIdsAtomic(int

size)

TableConstant.CONFIG_INFO;}Overridepublic

String

DataSourceConstant.ORCLE;}Overridepublic

String

src_ip?,src_user?,gmt_modified?,

app_name?,c_desc?,c_use?,effect?,type?,c_schema?

WHERE

http://www.apache.org/licenses/LICENSE-2.0**

Unless

com.alibaba.nacos.plugin.datasource.impl.oracle;import

com.alibaba.nacos.plugin.datasource.constants.DataSourceConstant;

import

com.alibaba.nacos.plugin.datasource.constants.TableConstant;

import

com.alibaba.nacos.plugin.datasource.mapper.AbstractMapper;

import

com.alibaba.nacos.plugin.datasource.mapper.ConfigInfoTagMapper;/***

The

findAllConfigInfoTagForDumpAllFetchRows(int

startRow,

t.id,data_id,group_id,tenant_id,tag_id,app_name,content,md5,gmt_modified

FROM

TableConstant.CONFIG_INFO_TAG;}Overridepublic

String

5.ConfigTagsRelationMapperByOracle

/**

http://www.apache.org/licenses/LICENSE-2.0**

Unless

com.alibaba.nacos.plugin.datasource.impl.oracle;import

com.alibaba.nacos.common.utils.StringUtils;

import

com.alibaba.nacos.plugin.datasource.constants.DataSourceConstant;

import

com.alibaba.nacos.plugin.datasource.constants.TableConstant;

import

com.alibaba.nacos.plugin.datasource.mapper.AbstractMapper;

import

com.alibaba.nacos.plugin.datasource.mapper.ConfigTagsRelationMapper;import

java.util.Map;/***

ConfigTagsRelationMapperByOracle

extends

findConfigInfo4PageCountRows(final

MapString,

params.get(group);StringBuilder

where

(StringUtils.isNotBlank(dataId))

{where.append(

(StringUtils.isNotBlank(group))

{where.append(

(StringUtils.isNotBlank(appName))

{where.append(

);}where.append(?);}where.append()

);return

findConfigInfo4PageFetchRows(MapString,

String

params.get(group);StringBuilder

where

a.id,a.data_id,a.group_id,a.tenant_id,a.app_name,a.content,

ROWNUM

(StringUtils.isNotBlank(dataId))

{where.append(

(StringUtils.isNotBlank(group))

{where.append(

(StringUtils.isNotBlank(appName))

{where.append(

);}where.append(?);}where.append()

);return

findConfigInfoLike4PageCountRows(final

MapString,

params.get(group);StringBuilder

where

(!StringUtils.isBlank(appName))

{where.append(

(!StringUtils.isBlank(content))

{where.append(

);}where.append(?);}where.append()

);return

findConfigInfoLike4PageFetchRows(final

MapString,

params.get(group);StringBuilder

where

a.id,a.data_id,a.group_id,a.tenant_id,a.app_name,a.content,

ROWNUM

(!StringUtils.isBlank(appName))

{where.append(

(!StringUtils.isBlank(content))

{where.append(

);}where.append(?);}where.append()

);return

TableConstant.CONFIG_TAGS_RELATION;}Overridepublic

String

http://www.apache.org/licenses/LICENSE-2.0**

Unless

com.alibaba.nacos.plugin.datasource.impl.oracle;import

com.alibaba.nacos.plugin.datasource.constants.DataSourceConstant;

import

com.alibaba.nacos.plugin.datasource.constants.TableConstant;

import

com.alibaba.nacos.plugin.datasource.mapper.AbstractMapper;

import

com.alibaba.nacos.plugin.datasource.mapper.GroupCapacityMapper;/***

The

TableConstant.GROUP_CAPACITY;}Overridepublic

String

DataSourceConstant.ORCLE;}Overridepublic

String

incrementUsageByWhereQuotaEqualZero()

{return

incrementUsageByWhereQuotaNotEqualZero()

{return

7.HistoryConfigInfoMapperByOracle

/**

http://www.apache.org/licenses/LICENSE-2.0**

Unless

com.alibaba.nacos.plugin.datasource.impl.oracle;import

com.alibaba.nacos.plugin.datasource.constants.DataSourceConstant;

import

com.alibaba.nacos.plugin.datasource.constants.TableConstant;

import

com.alibaba.nacos.plugin.datasource.mapper.AbstractMapper;

import

com.alibaba.nacos.plugin.datasource.mapper.HistoryConfigInfoMapper;/***

The

HistoryConfigInfoMapperByOracle

extends

nid,data_id,group_id,tenant_id,app_name,src_ip,src_user,op_type,gmt_create,gmt_modified

FROM

nid,data_id,group_id,tenant_id,app_name,content,md5,src_user,src_ip,op_type,gmt_create,gmt_modified

FROM

TableConstant.HIS_CONFIG_INFO;}Overridepublic

String

http://www.apache.org/licenses/LICENSE-2.0**

Unless

com.alibaba.nacos.plugin.datasource.impl.oracle;import

com.alibaba.nacos.plugin.datasource.constants.DataSourceConstant;

import

com.alibaba.nacos.plugin.datasource.constants.TableConstant;

import

com.alibaba.nacos.plugin.datasource.mapper.AbstractMapper;

import

com.alibaba.nacos.plugin.datasource.mapper.TenantCapacityMapper;/***

The

TableConstant.TENANT_CAPACITY;}Overridepublic

String

DataSourceConstant.ORCLE;}Overridepublic

String

incrementUsageWithDefaultQuotaLimit()

{return

http://www.apache.org/licenses/LICENSE-2.0**

Unless

com.alibaba.nacos.plugin.datasource.impl.oracle;import

com.alibaba.nacos.plugin.datasource.constants.DataSourceConstant;

import

com.alibaba.nacos.plugin.datasource.constants.TableConstant;

import

com.alibaba.nacos.plugin.datasource.mapper.AbstractMapper;

import

com.alibaba.nacos.plugin.datasource.mapper.TenantInfoMapper;/***

The

TableConstant.TENANT_INFO;}Overridepublic

String

com.alibaba.nacos.plugin.datasource.mapper.Mapper修改

修改类plugin/datasource/src/main/resources/META-INF/services/com.alibaba.nacos.plugin.datasource.mapper.Mapper

Copyright

http://www.apache.org/licenses/LICENSE-2.0

Unless

#com.alibaba.nacos.plugin.datasource.impl.mysql.ConfigInfoAggrMapperByMySql

com.alibaba.nacos.plugin.datasource.impl.mysql.ConfigInfoBetaMapperByMySql

com.alibaba.nacos.plugin.datasource.impl.mysql.ConfigInfoMapperByMySql

com.alibaba.nacos.plugin.datasource.impl.mysql.ConfigInfoTagMapperByMySql

com.alibaba.nacos.plugin.datasource.impl.mysql.ConfigTagsRelationMapperByMySql

com.alibaba.nacos.plugin.datasource.impl.mysql.HistoryConfigInfoMapperByMySql

com.alibaba.nacos.plugin.datasource.impl.mysql.TenantInfoMapperByMySql

com.alibaba.nacos.plugin.datasource.impl.mysql.TenantCapacityMapperByMySql

com.alibaba.nacos.plugin.datasource.impl.mysql.GroupCapacityMapperByMysqlcom.alibaba.nacos.plugin.datasource.impl.derby.ConfigInfoAggrMapperByDerby

com.alibaba.nacos.plugin.datasource.impl.derby.ConfigInfoBetaMapperByDerby

com.alibaba.nacos.plugin.datasource.impl.derby.ConfigInfoMapperByDerby

com.alibaba.nacos.plugin.datasource.impl.derby.ConfigInfoTagMapperByDerby

com.alibaba.nacos.plugin.datasource.impl.derby.ConfigInfoTagsRelationMapperByDerby

com.alibaba.nacos.plugin.datasource.impl.derby.HistoryConfigInfoMapperByDerby

com.alibaba.nacos.plugin.datasource.impl.derby.TenantInfoMapperByDerby

com.alibaba.nacos.plugin.datasource.impl.derby.TenantCapacityMapperByDerby

com.alibaba.nacos.plugin.datasource.impl.derby.GroupCapacityMapperByDerbycom.alibaba.nacos.plugin.datasource.impl.oracle.ConfigInfoAggrMapperByOracle

com.alibaba.nacos.plugin.datasource.impl.oracle.ConfigInfoBetaMapperByOracle

com.alibaba.nacos.plugin.datasource.impl.oracle.ConfigInfoMapperByOracle

com.alibaba.nacos.plugin.datasource.impl.oracle.ConfigInfoTagMapperByOracle

com.alibaba.nacos.plugin.datasource.impl.oracle.ConfigTagsRelationMapperByOracle

com.alibaba.nacos.plugin.datasource.impl.oracle.HistoryConfigInfoMapperByOracle

com.alibaba.nacos.plugin.datasource.impl.oracle.TenantInfoMapperByOracle

com.alibaba.nacos.plugin.datasource.impl.oracle.TenantCapacityMapperByOracle

com.alibaba.nacos.plugin.datasource.impl.oracle.GroupCapacityMapperByOracle2.5

nacos-console模块修改

修改配置文件console/src/main/resources/application.properties

只修改一部分数据源连接信息截图如下

nacos.plugin.datasource.log.enabledtrue

###

db.url.0jdbc:oracle:thin:192.168.10.2:1521/xe

db.user.0nacos220

db.jdbcDriverNameoracle.jdbc.OracleDriver

db.testQueryselect

在nacos-all下的target就会出现压缩文件了这样就相当于从nacos官网直接下载的压缩包具体nacos配置可以自行完成。

以上就是Nacos2.2.0多数据源适配oracle12C-修改Nacos源码的步骤