Commit f24c7a02 by 张祺

去除mongdb依赖

parent 5493cd4d
...@@ -27,10 +27,10 @@ ...@@ -27,10 +27,10 @@
</properties> </properties>
<dependencies> <dependencies>
<dependency> <!--<dependency>-->
<groupId>org.springframework.boot</groupId> <!--<groupId>org.springframework.boot</groupId>-->
<artifactId>spring-boot-starter-data-mongodb</artifactId> <!--<artifactId>spring-boot-starter-data-mongodb</artifactId>-->
</dependency> <!--</dependency>-->
<dependency> <dependency>
<groupId>org.springframework.cloud</groupId> <groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
......
package com.keymobile.indicators.conf;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.config.AbstractMongoConfiguration;
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
import org.springframework.data.mongodb.gridfs.GridFsTemplate;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.gridfs.GridFSBucket;
import com.mongodb.client.gridfs.GridFSBuckets;
@Configuration
public class MongoDBConfig extends AbstractMongoConfiguration {
@Value("${mongodb.uri}")
private String host;
@Value("${mongodb.database}")
private String database;
@Value("${mongodb.username}")
private String user;
@Value("${mongodb.password}")
private String pswd;
@Value("${mongodb.maxConnectionIdleTime}")
private Integer maxConnectionIdleTime = 60000;
@Override
protected String getDatabaseName() {
return database;
}
@Bean
public MongoDbFactory mongoDbFactory() {
return new SimpleMongoDbFactory(this.mongoClient(), this.getDatabaseName());
}
@Bean
public GridFsTemplate gridFsTemplate() throws Exception {
return new GridFsTemplate(mongoDbFactory(), mappingMongoConverter());
}
@Bean
public GridFSBucket getGridFSBuckets() {
MongoDatabase db = mongoDbFactory().getDb();
return GridFSBuckets.create(db);
}
@Override
public MongoClient mongoClient() {
String uri = String.format("mongodb://%s:%s@%s/%s", user, pswd, host, database);
MongoClientOptions.Builder builder = new MongoClientOptions.Builder();
builder.maxConnectionIdleTime(maxConnectionIdleTime);
MongoClientURI clientURI = new MongoClientURI(uri, builder);
return new MongoClient(clientURI);
}
}
package com.keymobile.indicators.model.entity; package com.keymobile.indicators.model.entity;
import lombok.Data; import lombok.Data;
import org.springframework.data.mongodb.core.mapping.Field;
import java.util.Date; import java.util.Date;
...@@ -15,7 +14,6 @@ public abstract class BaseModel { ...@@ -15,7 +14,6 @@ public abstract class BaseModel {
/** /**
* 数据状态 * 数据状态
*/ */
@Field("state")
private Integer state; private Integer state;
/** /**
...@@ -32,13 +30,11 @@ public abstract class BaseModel { ...@@ -32,13 +30,11 @@ public abstract class BaseModel {
/** /**
* 创建时间 * 创建时间
*/ */
@Field("update_time")
private Date updateTime; private Date updateTime;
/** /**
* 创建时间 * 创建时间
*/ */
@Field("create_time")
private Date createTime; private Date createTime;
} }
...@@ -3,8 +3,6 @@ package com.keymobile.indicators.model.entity; ...@@ -3,8 +3,6 @@ package com.keymobile.indicators.model.entity;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import org.springframework.data.annotation.Id; import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;
import javax.persistence.Table; import javax.persistence.Table;
import java.io.Serializable; import java.io.Serializable;
...@@ -13,7 +11,6 @@ import java.io.Serializable; ...@@ -13,7 +11,6 @@ import java.io.Serializable;
* 配置项对象 * 配置项对象
*/ */
@Data @Data
@Document(collection = "config_info")
@Table(name="config_info") @Table(name="config_info")
public class ConfigInfo extends BaseModel implements Serializable { public class ConfigInfo extends BaseModel implements Serializable {
...@@ -32,18 +29,15 @@ public class ConfigInfo extends BaseModel implements Serializable { ...@@ -32,18 +29,15 @@ public class ConfigInfo extends BaseModel implements Serializable {
* 配置项的值 * 配置项的值
*/ */
@ApiModelProperty(value="配置项的值", required = true) @ApiModelProperty(value="配置项的值", required = true)
@Field("cf_value")
private String cfValue; private String cfValue;
/** /**
* 配置项描述 * 配置项描述
*/ */
@ApiModelProperty(value="配置项描述") @ApiModelProperty(value="配置项描述")
@Field("cf_desc")
private String cfDesc; private String cfDesc;
/** /**
* 配置项所属模块 * 配置项所属模块
*/ */
@ApiModelProperty(value="配置项所属模块") @ApiModelProperty(value="配置项所属模块")
@Field("module")
private String module; private String module;
} }
package com.keymobile.indicators.persistence.hyindicators;
import com.keymobile.indicators.model.entity.ConfigInfo;
import org.springframework.data.mongodb.repository.MongoRepository;
/**
* 配置项数据层接口
*/
public interface ConfigInfoRepository extends MongoRepository<ConfigInfo, String> {
}
mongodb:
uri: 139.198.127.54:9017
database: dev0
username: root
password: dataPlatform
maxConnectionIdleTime: 600000
spring: spring:
application: application:
name: indicators name: indicators
...@@ -35,7 +28,7 @@ server: ...@@ -35,7 +28,7 @@ server:
eureka: eureka:
client: client:
registerWithEureka: true registerWithEureka: false
region: default region: default
registryFetchIntervalSeconds: 5 registryFetchIntervalSeconds: 5
serviceUrl: serviceUrl:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment