记得上下班打卡 | git大法好,push需谨慎
Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
L
liquidnet-bus-v1
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
董敬伟
liquidnet-bus-v1
Commits
8aa137ae
Commit
8aa137ae
authored
Jul 29, 2021
by
张国柄
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
fix:去除MONGO;
parent
ac10a5a2
Changes
14
Hide whitespace changes
Inline
Side-by-side
Showing
14 changed files
with
27 additions
and
470 deletions
+27
-470
liquidnet-service-account-dev.yml
...config/liquidnet-config/liquidnet-service-account-dev.yml
+0
-10
liquidnet-service-account.yml
...bus-config/liquidnet-config/liquidnet-service-account.yml
+0
-124
liquidnet-service-adam.yml
...et-bus-config/liquidnet-config/liquidnet-service-adam.yml
+5
-5
liquidnet-service-bank-dev.yml
...us-config/liquidnet-config/liquidnet-service-bank-dev.yml
+0
-44
liquidnet-service-bank.yml
...et-bus-config/liquidnet-config/liquidnet-service-bank.yml
+0
-97
liquidnet-service-dragon.yml
...-bus-config/liquidnet-config/liquidnet-service-dragon.yml
+3
-1
liquidnet-service-kylin.yml
...t-bus-config/liquidnet-config/liquidnet-service-kylin.yml
+3
-1
liquidnet-service-notify.yml
...-bus-config/liquidnet-config/liquidnet-service-notify.yml
+3
-1
liquidnet-service-order.yml
...t-bus-config/liquidnet-config/liquidnet-service-order.yml
+3
-1
pom.xml
...iquidnet-service-adam/liquidnet-service-adam-impl/pom.xml
+4
-4
bootstrap-service-adam.yml
...e-adam-impl/src/main/resources/bootstrap-service-adam.yml
+6
-6
TestMongodbHashIndexCreate.java
...quidnet/service/adam/test/TestMongodbHashIndexCreate.java
+0
-62
TestMongodbIndexCreate.java
...m/liquidnet/service/adam/test/TestMongodbIndexCreate.java
+0
-62
TestMongodbIndexCreateExample.java
...dnet/service/adam/test/TestMongodbIndexCreateExample.java
+0
-52
No files found.
liquidnet-bus-config/liquidnet-config/liquidnet-service-account-dev.yml
deleted
100644 → 0
View file @
ac10a5a2
liquidnet
:
info
:
port
:
9003
context
:
/service-account
name
:
liquidnet-service-account
logfile
:
path
:
/data/logs
name
:
service-account
mysql
:
database-name
:
liquidnet_wac
liquidnet-bus-config/liquidnet-config/liquidnet-service-account.yml
deleted
100644 → 0
View file @
ac10a5a2
server
:
port
:
${liquidnet.info.port}
tomcat
:
uri-encoding
:
UTF-8
servlet
:
context-path
:
${liquidnet.info.context}
# -----------------------------------------------------------
knife4j
:
production
:
${liquidnet.knife4j.disable}
basic
:
enable
:
true
username
:
${liquidnet.security.username}
password
:
${liquidnet.security.password}
# -----------------------------------------------------------
logging
:
file
:
name
:
${liquidnet.logfile.path}/${liquidnet.logfile.name}.log
max-size
:
200MB
pattern
:
file
:
'
%d{yyyy-MM-dd
HH:mm:ss.SSS}
[
%-5level]
%thread
[%logger{96}:%line]
-
%msg%n'
console
:
'
%d{yyyy-MM-dd
HH:mm:ss.SSS}
[
%-5level]
%thread
[%logger{96}:%line]
-
%msg%n'
rolling-file-name
:
${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
level
:
root
:
info
#以下是为指定包设置日志级别
# com:
# liquidnet: info
# -----------------------------------------------------------
eureka
:
# client:
# register-with-eureka: true
# fetch-registry: true
# serviceUrl:
# defaultZone: http://${liquidnet.security.username}:${liquidnet.security.password}@${liquidnet.eureka.host}/eureka-server/eureka
instance
:
hostname
:
${spring.cloud.client.ip-address}
lease-expiration-duration-in-seconds
:
15
#服务过期时间配置,超过这个时间没有接收到心跳EurekaServer就会将这个实例剔除
lease-renewal-interval-in-seconds
:
5
#服务刷新时间配置,每隔这个时间会主动心跳一次
prefer-ip-address
:
true
instance-id
:
${spring.application.name}:${spring.cloud.client.ip-address}:${spring.application.instance_id:${server.port}}
# -----------------------------------------------------------
#actuator/info
info
:
app
:
name
:
${liquidnet.info.name}
company
:
name
:
lightnet.io
build
:
groupId
:
'
@project.groupId@'
artifactId
:
'
@project.artifactId@'
version
:
'
@project.version@'
# -----------------------------------------------------------
pagehelper
:
helperDialect
:
mysql
reasonable
:
true
supportMethodsArguments
:
true
params
:
count=countSql
# -----------------------------------------------------------
xxl
:
job
:
admin
:
addresses
:
http://127.0.0.1:8090/
accessToken
:
executor
:
appname
:
liquidnetTaskService
address
:
ip
:
port
:
9102
logpath
:
/data/applogs/xxl-job/jobhandler
logretentiondays
:
3
# -----------------------------------------------------------
spring
:
application
:
name
:
${liquidnet.info.name}
autoconfigure
:
exclude
:
org.springframework.cloud.bus.BusAutoConfiguration, org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration, org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration, org.springframework.boot.autoconfigure.data.redis.RedisRepositoriesAutoConfiguration
cloud
:
refresh
:
extra-refreshable
:
none
rabbitmq
:
addresses
:
${liquidnet.rabbitmq.host}
port
:
${liquidnet.rabbitmq.port}
username
:
${liquidnet.rabbitmq.username}
password
:
${liquidnet.rabbitmq.password}
shardingsphere
:
props
:
sql
:
show
:
false
simple
:
true
datasource
:
names
:
db0
db0
:
type
:
org.apache.commons.dbcp2.BasicDataSource
# driver-class-name: com.mysql.cj.jdbc.Driver
url
:
jdbc:mysql://${liquidnet.mysql.urlHostAndPort}/${liquidnet.mysql.database-name}?serverTimezone=UTC&zeroDateTimeBehavior=convertToNull&characterEncoding=utf-8&useSSL=false&autoReconnect=true
username
:
${liquidnet.mysql.username}
password
:
${liquidnet.mysql.password}
initialSize
:
10
maxTotal
:
50
maxIdle
:
10
# minIdle: 0
timeBetweenEvictionRunsMillis
:
6000
validationQuery
:
select 1
testWhileIdle
:
true
testOnBorrow
:
false
poolPreparedStatements
:
true
maxOpenPreparedStatements
:
100
sharding
:
tables
:
FIN_AC_N02
:
actualDataNodes
:
db${0}.FIN_AC_N02_${0..24}
logicTable
:
FIN_AC_N02
tableStrategy
:
standard
:
sharding-column
:
FA1
precise-algorithm-class-name
:
com.liquidnet.common.sharding.jdbc.algorithm.ModuloShardingTableAlgorithm
range-algorithm-class-name
:
com.liquidnet.common.sharding.jdbc.algorithm.ModuloShardingTableAlgorithm
# inline:
# algorithmExpression: FIN_AC_N11_${FA1 % 25}
# shardingColumn: fin_id
# -----------------------------------------------------------
# -----------------------------------------------------------
liquidnet-bus-config/liquidnet-config/liquidnet-service-adam.yml
View file @
8aa137ae
...
...
@@ -106,11 +106,11 @@ spring:
codec
:
class
:
"
org.redisson.codec.JsonJacksonCodec"
transportMode
:
"
NIO"
data
:
mongodb
:
uri
:
mongodb://${liquidnet.mongodb.user}:${liquidnet.mongodb.pwd}@${liquidnet.mongodb.host}/?authSource=admin&maxPoolSize=2000&waitQueueMultiple=100
sslEnabled
:
${liquidnet.mongodb.sslEnabled}
database
:
${liquidnet.mongodb.database}
#
data:
#
mongodb:
#
uri: mongodb://${liquidnet.mongodb.user}:${liquidnet.mongodb.pwd}@${liquidnet.mongodb.host}/?authSource=admin&maxPoolSize=2000&waitQueueMultiple=100
#
sslEnabled: ${liquidnet.mongodb.sslEnabled}
#
database: ${liquidnet.mongodb.database}
# -----------------------------------------------------------
# -----------------------------------------------------------
...
...
liquidnet-bus-config/liquidnet-config/liquidnet-service-bank-dev.yml
deleted
100644 → 0
View file @
ac10a5a2
liquidnet
:
info
:
port
:
9002
context
:
/service-bank
name
:
liquidnet-service-bank
logfile
:
path
:
/data/logs
name
:
service-bank
config
:
classpath:logback-spring.xml
file-max-size
:
200MB
pattern-file
:
'
%d{yyyy-MM-dd
HH:mm:ss.SSS}
[
%-5level]
%thread
[%logger{96}:%line]
-
%msg%n'
pattern-console
:
'
%d{yyyy-MM-dd
HH:mm:ss.SSS}
[
%-5level]
%thread
[%logger{96}:%line]
-
%msg%n'
pattern-rolling-file-name
:
${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
level-root
:
info
mysql
:
database-name
:
liquidnet_bank
conf
:
currencycloud
:
email_address
:
liquidnet@lightnet.io
auth
:
environment
:
demo
login_id
:
michael.ran@lightnet.io
api_key
:
745dbaee98a8b7115df3696b6fa7b48959294c34117e7240ebcd1e07268a9bad
#以下为spring各环境个性配置
spring
:
rabbitmq
:
addresses
:
${liquidnet.rabbitmq.host}
port
:
${liquidnet.rabbitmq.port}
username
:
${liquidnet.rabbitmq.username}
password
:
${liquidnet.rabbitmq.password}
redis
:
port
:
${liquidnet.redis.port}
host
:
${liquidnet.redis.host}
password
:
${liquidnet.redis.password}
lettuce
:
pool
:
max-active
:
8
max-wait
:
-1
max-idle
:
8
min-idle
:
0
data
:
mongodb
:
uri
:
mongodb://${liquidnet.mongodb.host}:${liquidnet.mongodb.port}/${liquidnet.mongodb.gfsdatabasename}
liquidnet-bus-config/liquidnet-config/liquidnet-service-bank.yml
deleted
100644 → 0
View file @
ac10a5a2
server
:
port
:
${liquidnet.info.port}
tomcat
:
uri-encoding
:
UTF-8
servlet
:
context-path
:
${liquidnet.info.context}
# -----------------------------------------------------------
knife4j
:
production
:
${liquidnet.knife4j.disable}
basic
:
enable
:
true
username
:
${liquidnet.security.username}
password
:
${liquidnet.security.password}
# -----------------------------------------------------------
logging
:
config
:
${liquidnet.logfile.config}
# file:
# name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}.log
# max-size: 200MB
# pattern:
# file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
# console: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{96}:%line] - %msg%n'
# rolling-file-name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
# level:
# root: info
#以下是为指定包设置日志级别
# com:
# liquidnet: info
# -----------------------------------------------------------
eureka
:
# client:
# register-with-eureka: true
# fetch-registry: true
# serviceUrl:
# defaultZone: http://${liquidnet.security.username}:${liquidnet.security.password}@${liquidnet.eureka.host}/eureka-server/eureka
instance
:
hostname
:
${spring.cloud.client.ip-address}
lease-expiration-duration-in-seconds
:
15
#服务过期时间配置,超过这个时间没有接收到心跳EurekaServer就会将这个实例剔除
lease-renewal-interval-in-seconds
:
5
#服务刷新时间配置,每隔这个时间会主动心跳一次
prefer-ip-address
:
true
instance-id
:
${spring.application.name}:${spring.cloud.client.ip-address}:${spring.application.instance_id:${server.port}}
# -----------------------------------------------------------
#actuator/info
info
:
app
:
name
:
${liquidnet.info.name}
company
:
name
:
lightnet.io
build
:
groupId
:
'
@project.groupId@'
artifactId
:
'
@project.artifactId@'
version
:
'
@project.version@'
# -----------------------------------------------------------
mybatis-plus
:
mapper-locations
:
classpath:com.liquidnet.service.bank.mapper/*Mapper.xml
global-config
:
db-config
:
logic-delete-field
:
is_active
logic-delete-value
:
false
logic-not-delete-value
:
true
# -----------------------------------------------------------
spring
:
application
:
name
:
${liquidnet.info.name}
autoconfigure
:
exclude
:
org.springframework.cloud.bus.BusAutoConfiguration, org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration
datasource
:
name
:
liquidnet_bus_db
url
:
jdbc:mysql://${liquidnet.mysql.urlHostAndPort}/${liquidnet.mysql.database-name}?serverTimezone=UTC&characterEncoding=utf-8&useSSL=false
username
:
${liquidnet.mysql.username}
password
:
${liquidnet.mysql.password}
# type: org.apache.tomcat.jdbc.pool.DataSource
driver-class-name
:
com.mysql.cj.jdbc.Driver
filters
:
stat
maxActive
:
20
initialSize
:
1
maxWait
:
60000
minIdle
:
1
timeBetweenEvictionRunsMillis
:
60000
minEvictableIdleTimeMillis
:
300000
validationQuery
:
select 'x'
testWhileIdle
:
true
testOnBorrow
:
false
testOnReturn
:
false
poolPreparedStatements
:
true
maxOpenPreparedStatements
:
20
mvc
:
static-path-pattern
:
/templates/**
# 定位模板的目录
view
:
prefix
:
classpath:/templates/
suffix
:
.html
resources
:
static-locations
:
classpath:/templates/,classpath:/static/page
# -----------------------------------------------------------
# -----------------------------------------------------------
liquidnet-bus-config/liquidnet-config/liquidnet-service-dragon.yml
View file @
8aa137ae
...
...
@@ -70,7 +70,9 @@ spring:
profiles
:
include
:
common-service
#这里加载management相关公共配置
autoconfigure
:
exclude
:
org.springframework.cloud.bus.BusAutoConfiguration,org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
exclude
:
-
org.springframework.cloud.bus.BusAutoConfiguration
-
org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
redis
:
database
:
0
port
:
${liquidnet.redis.dragon.port}
...
...
liquidnet-bus-config/liquidnet-config/liquidnet-service-kylin.yml
View file @
8aa137ae
...
...
@@ -70,7 +70,9 @@ spring:
profiles
:
include
:
common-service
#这里加载management相关公共配置
autoconfigure
:
exclude
:
org.springframework.cloud.bus.BusAutoConfiguration,org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
exclude
:
-
org.springframework.cloud.bus.BusAutoConfiguration
-
org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
redis
:
database
:
15
port
:
${liquidnet.redis.port}
...
...
liquidnet-bus-config/liquidnet-config/liquidnet-service-notify.yml
View file @
8aa137ae
...
...
@@ -70,7 +70,9 @@ spring:
profiles
:
include
:
common-service
#这里加载management相关公共配置
autoconfigure
:
exclude
:
org.springframework.cloud.bus.BusAutoConfiguration,org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
exclude
:
-
org.springframework.cloud.bus.BusAutoConfiguration
-
org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
rabbitmq
:
addresses
:
${liquidnet.rabbitmq.host}
port
:
${liquidnet.rabbitmq.port}
...
...
liquidnet-bus-config/liquidnet-config/liquidnet-service-order.yml
View file @
8aa137ae
...
...
@@ -70,7 +70,9 @@ spring:
profiles
:
include
:
common-service
#这里加载management相关公共配置
autoconfigure
:
exclude
:
org.springframework.cloud.bus.BusAutoConfiguration,org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
exclude
:
-
org.springframework.cloud.bus.BusAutoConfiguration
-
org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration
redis
:
database
:
15
port
:
${liquidnet.redis.port}
...
...
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/pom.xml
View file @
8aa137ae
...
...
@@ -33,10 +33,10 @@
<artifactId>
liquidnet-common-cache-redisson
</artifactId>
<version>
1.0-SNAPSHOT
</version>
</dependency>
<dependency
>
<groupId>
org.springframework.boot
</groupId
>
<artifactId>
spring-boot-starter-data-mongodb
</artifactId
>
</dependency
>
<!-- <dependency>--
>
<!-- <groupId>org.springframework.boot</groupId>--
>
<!-- <artifactId>spring-boot-starter-data-mongodb</artifactId>--
>
<!-- </dependency>--
>
<dependency>
<groupId>
com.liquidnet
</groupId>
...
...
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/resources/bootstrap-service-adam.yml
View file @
8aa137ae
...
...
@@ -9,9 +9,9 @@ eureka:
spring
:
cloud
:
config
:
# uri: http://127.0.0.1:7002/support-config
profile
:
${liquidnet.cloudConfig.profile}
name
:
${spring.application.name}
#默认为spring.application.name
discovery
:
enabled
:
true
service-id
:
liquidnet-support-config
\ No newline at end of file
uri
:
http://127.0.0.1:7002/support-config
# profile: ${liquidnet.cloudConfig.profile}
# name: ${spring.application.name} #默认为spring.application.name
# discovery:
# enabled: true
# service-id: liquidnet-support-config
\ No newline at end of file
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/test/java/com/liquidnet/service/adam/test/TestMongodbHashIndexCreate.java
deleted
100644 → 0
View file @
ac10a5a2
package
com
.
liquidnet
.
service
.
adam
.
test
;
import
com.mongodb.BasicDBObject
;
import
com.mongodb.client.model.IndexModel
;
import
org.junit.Test
;
import
org.junit.runner.RunWith
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.boot.test.context.SpringBootTest
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.test.context.junit4.SpringJUnit4ClassRunner
;
import
java.util.ArrayList
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.Map
;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: TestMongodbIndexCreate
* @Package com.liquidnet.service.adam.test
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/6/7 17:02
*/
@RunWith
(
SpringJUnit4ClassRunner
.
class
)
@SpringBootTest
public
class
TestMongodbHashIndexCreate
{
@Autowired
private
MongoTemplate
mongoTemplate
;
@Test
public
void
createMongodbIndex
(){
String
[]
collectionNames
=
{
"AdamUserInfoVo"
,
"AdamRealInfoVo"
,
"AdamThirdPartInfoVo"
,
"AdamUserMemberVo"
,
"AdamMemberVo"
};
HashMap
<
String
,
String
[]>
colNameMap
=
new
HashMap
();
colNameMap
.
put
(
"AdamUserInfoVo"
,
new
String
[]{
"uid"
,
"state"
});
colNameMap
.
put
(
"AdamRealInfoVo"
,
new
String
[]{
"uid"
,
"state"
});
colNameMap
.
put
(
"AdamThirdPartInfoVo"
,
new
String
[]{
"uid"
,
"state"
});
colNameMap
.
put
(
"AdamUserMemberVo"
,
new
String
[]{
"uid"
});
colNameMap
.
put
(
"AdamMemberVo"
,
new
String
[]{
"member_id"
});
for
(
String
collectionName:
collectionNames
){
if
(
mongoTemplate
.
collectionExists
(
collectionName
)){
System
.
out
.
printf
(
"执行错误!"
);
return
;
}
for
(
Map
.
Entry
<
String
,
String
[]>
entry:
colNameMap
.
entrySet
())
{
System
.
out
.
print
(
entry
.
getKey
()
+
":"
+
entry
.
getValue
()
+
"\t"
);
if
(
entry
.
getKey
().
equalsIgnoreCase
(
collectionName
)){
//需要创建的索引集合
List
<
IndexModel
>
indexModels
=
new
ArrayList
<>();
String
[]
indexColArray
=
entry
.
getValue
();
for
(
String
indexName:
indexColArray
){
BasicDBObject
index1
=
new
BasicDBObject
();
index1
.
put
(
indexName
,
"hashed"
);
indexModels
.
add
(
new
IndexModel
(
index1
));
}
mongoTemplate
.
createCollection
(
collectionName
).
createIndexes
(
indexModels
);
}
}
}
}
}
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/test/java/com/liquidnet/service/adam/test/TestMongodbIndexCreate.java
deleted
100644 → 0
View file @
ac10a5a2
package
com
.
liquidnet
.
service
.
adam
.
test
;
import
com.mongodb.BasicDBObject
;
import
com.mongodb.client.model.IndexModel
;
import
org.junit.Test
;
import
org.junit.runner.RunWith
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.boot.test.context.SpringBootTest
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.test.context.junit4.SpringJUnit4ClassRunner
;
import
java.util.ArrayList
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.Map
;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: TestMongodbIndexCreate
* @Package com.liquidnet.service.adam.test
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/6/7 17:02
*/
@RunWith
(
SpringJUnit4ClassRunner
.
class
)
@SpringBootTest
public
class
TestMongodbIndexCreate
{
@Autowired
private
MongoTemplate
mongoTemplate
;
@Test
public
void
createMongodbIndex
(){
String
[]
collectionNames
=
{
"AdamUserInfoVo"
,
"AdamRealInfoVo"
,
"AdamThirdPartInfoVo"
,
"AdamUserMemberVo"
,
"AdamMemberVo"
};
HashMap
<
String
,
String
[]>
colNameMap
=
new
HashMap
();
colNameMap
.
put
(
"AdamUserInfoVo"
,
new
String
[]{
"uid"
,
"state"
});
colNameMap
.
put
(
"AdamRealInfoVo"
,
new
String
[]{
"uid"
,
"state"
});
colNameMap
.
put
(
"AdamThirdPartInfoVo"
,
new
String
[]{
"uid"
,
"state"
});
colNameMap
.
put
(
"AdamUserMemberVo"
,
new
String
[]{
"uid"
});
colNameMap
.
put
(
"AdamMemberVo"
,
new
String
[]{
"member_id"
});
for
(
String
collectionName:
collectionNames
){
if
(
mongoTemplate
.
collectionExists
(
collectionName
)){
System
.
out
.
printf
(
"执行错误!"
);
return
;
}
for
(
Map
.
Entry
<
String
,
String
[]>
entry:
colNameMap
.
entrySet
())
{
System
.
out
.
print
(
entry
.
getKey
()
+
":"
+
entry
.
getValue
()
+
"\t"
);
if
(
entry
.
getKey
().
equalsIgnoreCase
(
collectionName
)){
//需要创建的索引集合
List
<
IndexModel
>
indexModels
=
new
ArrayList
<>();
String
[]
indexColArray
=
entry
.
getValue
();
for
(
String
indexName:
indexColArray
){
BasicDBObject
index1
=
new
BasicDBObject
();
index1
.
put
(
indexName
,
1
);
indexModels
.
add
(
new
IndexModel
(
index1
));
}
mongoTemplate
.
createCollection
(
collectionName
).
createIndexes
(
indexModels
);
}
}
}
}
}
liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/test/java/com/liquidnet/service/adam/test/TestMongodbIndexCreateExample.java
deleted
100644 → 0
View file @
ac10a5a2
package
com
.
liquidnet
.
service
.
adam
.
test
;
import
com.mongodb.BasicDBObject
;
import
com.mongodb.client.model.IndexModel
;
import
org.junit.Test
;
import
org.junit.runner.RunWith
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.boot.test.context.SpringBootTest
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.test.context.junit4.SpringJUnit4ClassRunner
;
import
java.util.ArrayList
;
import
java.util.List
;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: TestMongodbIndexCreate
* @Package com.liquidnet.service.adam.test
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/6/7 17:02
*/
@RunWith
(
SpringJUnit4ClassRunner
.
class
)
@SpringBootTest
public
class
TestMongodbIndexCreateExample
{
@Autowired
private
MongoTemplate
mongoTemplate
;
@Test
public
void
createMongodbIndex
(){
String
[]
collectionNames
=
{
"test-mongo"
};
// String[] collectionNames = {"AdamUserInfoVo","AdamRealInfoVo","AdamThirdPartInfoVo","AdamUserMemberVo","AdamMemberVo"};
for
(
String
collectionName:
collectionNames
){
if
(
mongoTemplate
.
collectionExists
(
collectionName
)){
System
.
out
.
printf
(
"执行错误!"
);
return
;
}
//需要创建的索引集合
List
<
IndexModel
>
indexModels
=
new
ArrayList
<>();
BasicDBObject
index1
=
new
BasicDBObject
();
index1
.
put
(
"name"
,
1
);
indexModels
.
add
(
new
IndexModel
(
index1
));
BasicDBObject
index2
=
new
BasicDBObject
();
index2
.
put
(
"name"
,
1
);
index2
.
put
(
"age"
,
1
);
indexModels
.
add
(
new
IndexModel
((
index2
)));
mongoTemplate
.
createCollection
(
collectionName
).
createIndexes
(
indexModels
);
}
}
}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment