摄影网站的实验设计方案,六安网约车收入怎么样,应届毕业生简历模板,在哪里查商标注册信息大家好#xff0c;我是烤鸭#xff1a;这是一篇关于springboot项目中使用mongodb。
环境#xff1a;jdk 1.8springboot 1.5.6.RELEASEmaven 3.5
1. mongodb在springboot中的配置springboot集成这个三方插件就是简单#xff0c;只需要引入依赖#xff0c;在properties或者…大家好我是烤鸭这是一篇关于springboot项目中使用mongodb。
环境jdk 1.8springboot 1.5.6.RELEASEmaven 3.5
1. mongodb在springboot中的配置springboot集成这个三方插件就是简单只需要引入依赖在properties或者yml中
添加相应的参数配置就好了。(1) 引入依赖以maven为例其中mongodb两个依赖包dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-mongodb/artifactIdversion1.5.6.RELEASE/version/dependencydependencygroupIdorg.mongodb/groupIdartifactIdmongodb-driver/artifactIdversion3.4.2/version/dependency2properties或者yml配置我这次没用到这个配置是在工具类代码中直接写的以yml为例
spring:data:mongodb:host: 127.0.0.1port: 27017username: musicpassword: musicdatabase: music这里几个参数就是IP地址端口号用户名密码数据库。
2. mongodb的使用1创建想存到mongo中的实体映射类继承Document类我这里是想存一些歌曲。MusicInfo.java:
package com.test.test.test.bean;import org.bson.BsonDocument;
import org.bson.BsonDocumentWrapper;
import org.bson.Document;
import org.bson.codecs.configuration.CodecRegistry;
import org.bson.types.ObjectId;import java.io.Serializable;/*** Created by */
public class MusicInfo extends Document implements Serializable {private Integer returnId;private Integer id;private String mid;private String desc;private String name;private String singerName;private String fileHash;private String hqHash;private String albumId;private String type; //平台标识private String keyword; //查询关键字/*** 无参构造*/public MusicInfo() {super();}/*** 全参构造添加到Map中*/public MusicInfo(Integer returnId, Long id, String mid, String desc, String name, String singerName, String fileHash, String hqHash, String albumId, String type) {super();this.append(returnId, returnId).append(id, id).append(mid, mid).append(desc, desc).append(name, name).append(singerName, singerName).append(fileHash, fileHash).append(albumId, albumId).append(type, type).append(keyword,keyword);}public MusicInfo(String keyword) {super();this.append(keyword, keyword);}/*** 该方法用于collection的update*/public void setUpdate(MusicInfo musicInfo) {this.append($set, musicInfo);}/*** mongo 中的_id** return*/public ObjectId get_Id() {return this.getObjectId(_id);}public void set_Id(ObjectId id) {this.append(_id, id);}public Integer getReturnId() {//return returnId;return this.getInteger(returnId);}public void setReturnId(Integer returnId) {//this.returnId returnId;this.append(returnId, returnId);}public Integer getId() {Integer integer this.getInteger(id);return integer;//return id;}public void setId(Integer id) {//this.id id;this.append(id, id);}public String getMid() {return this.getString(mid);//return mid;}public void setMid(String mid) {//this.mid mid;this.append(mid, mid);}public String getDesc() {return this.getString(desc);// return desc;}public void setDesc(String desc) {//this.desc desc;this.append(desc, desc);}public String getName() {return this.getString(name);// return name;}public void setName(String name) {this.append(name, name);// this.name name;}public String getSingerName() {return this.getString(singerName);// return singerName;}public void setSingerName(String singerName) {this.append(singerName, singerName);//this.singerName singerName;}public String getFileHash() {return this.getString(fileHash);//return fileHash;}public void setFileHash(String fileHash) {this.append(fileHash, fileHash);// this.fileHash fileHash;}public String getHqHash() {return this.getString(hqHash);//return hqHash;}public void setHqHash(String hqHash) {this.append(hqHash, hqHash);// this.hqHash hqHash;}public String getAlbumId() {return this.getString(albumId);//return albumId;}public void setAlbumId(String albumId) {this.append(albumId, albumId);// this.albumId albumId;}public String getType() {return this.getString(type);//return albumId;}public void setType(String type) {this.append(type, type);// this.albumId albumId;}public String getKeyword() {return this.getString(keyword);//return albumId;}public void setKeyword(String keyword) {this.append(keyword, keyword);// this.albumId albumId;}public TDocument BsonDocument toBsonDocument(ClassTDocument documentClass, CodecRegistry codecRegistry) {// TODO Auto-generated method stubreturn new BsonDocumentWrapperMusicInfo(this, codecRegistry.get(MusicInfo.class));}Overridepublic String toString() {return MusicInfo[ _id this.get_Id() \ albumId this.getAlbumId() \ , returnId this.getReturnId() , id this.getId() , mid this.getMid() \ , desc this.getDesc() \ , name this.getName() \ , singerName this.getSingerName() \ , fileHash this.getFileHash() \ , hqHash this.getHqHash() \ , type this.getType() \ ];}
}
(2) 创建歌曲对应操作mongodb的注册类实现 CollectibleCodec接口MusicInfoCodec.java:
package com.test.test.test.bean;import org.bson.*;
import org.bson.assertions.Assertions;
import org.bson.codecs.*;
import org.bson.codecs.configuration.CodecRegistry;import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.UUID;import static java.util.Arrays.asList;
import static org.bson.codecs.configuration.CodecRegistries.fromProviders;/*** Created by .***/
public class MusicInfoCodec implements CollectibleCodecMusicInfo {private static final String ID_FIELD_NAME _id;private static final CodecRegistry DEFAULT_REGISTRY fromProviders(asList(new ValueCodecProvider(),new BsonValueCodecProvider(),new DocumentCodecProvider()));private static final BsonTypeClassMap DEFAULT_BSON_TYPE_CLASS_MAP new BsonTypeClassMap();private final CodecRegistry registry;private final BsonTypeClassMap bsonTypeClassMap;private final IdGenerator idGenerator;private final Transformer valueTransformer;public MusicInfoCodec() {this(DEFAULT_REGISTRY, DEFAULT_BSON_TYPE_CLASS_MAP);}public MusicInfoCodec(final CodecRegistry registry, final BsonTypeClassMap bsonTypeClassMap) {this(registry, bsonTypeClassMap, null);}public MusicInfoCodec(final CodecRegistry registry, final BsonTypeClassMap bsonTypeClassMap, final Transformer valueTransformer) {this.registry Assertions.notNull(registry, registry);this.bsonTypeClassMap Assertions.notNull(bsonTypeClassMap, bsonTypeClassMap);this.idGenerator Assertions.notNull(idGenerator, new ObjectIdGenerator());this.valueTransformer valueTransformer ! null ? valueTransformer : new Transformer() {Overridepublic Object transform(final Object value) {return value;}};}Overridepublic boolean documentHasId(final MusicInfo document) {return document.containsKey(ID_FIELD_NAME);}Overridepublic BsonValue getDocumentId(final MusicInfo document) {if (!documentHasId(document)) {throw new IllegalStateException(The document does not contain an _id);}Object id document.get(ID_FIELD_NAME);if (id instanceof BsonValue) {return (BsonValue) id;}BsonDocument idHoldingDocument new BsonDocument();BsonWriter writer new BsonDocumentWriter(idHoldingDocument);writer.writeStartDocument();writer.writeName(ID_FIELD_NAME);writeValue(writer, EncoderContext.builder().build(), id);writer.writeEndDocument();return idHoldingDocument.get(ID_FIELD_NAME);}Overridepublic MusicInfo generateIdIfAbsentFromDocument(final MusicInfo document) {if (!documentHasId(document)) {document.put(ID_FIELD_NAME, idGenerator.generate());}return document;}Overridepublic void encode(final BsonWriter writer, final MusicInfo document, final EncoderContext encoderContext) {writeMap(writer, document, encoderContext);}Overridepublic MusicInfo decode(final BsonReader reader, final DecoderContext decoderContext) {MusicInfo document new MusicInfo();reader.readStartDocument();while (reader.readBsonType() ! BsonType.END_OF_DOCUMENT) {String fieldName reader.readName();document.put(fieldName, readValue(reader, decoderContext));}reader.readEndDocument();return document;}Overridepublic ClassMusicInfo getEncoderClass() {return MusicInfo.class;}private void beforeFields(final BsonWriter bsonWriter, final EncoderContext encoderContext, final MapString, Object document) {if (encoderContext.isEncodingCollectibleDocument() document.containsKey(ID_FIELD_NAME)) {bsonWriter.writeName(ID_FIELD_NAME);writeValue(bsonWriter, encoderContext, document.get(ID_FIELD_NAME));}}private boolean skipField(final EncoderContext encoderContext, final String key) {return encoderContext.isEncodingCollectibleDocument() key.equals(ID_FIELD_NAME);}SuppressWarnings({unchecked, rawtypes})private void writeValue(final BsonWriter writer, final EncoderContext encoderContext, final Object value) {if (value null) {writer.writeNull();} else if (Iterable.class.isAssignableFrom(value.getClass())) {writeIterable(writer, (IterableObject) value, encoderContext.getChildContext());} else if (Map.class.isAssignableFrom(value.getClass())) {writeMap(writer, (MapString, Object) value, encoderContext.getChildContext());} else {Codec codec registry.get(value.getClass());encoderContext.encodeWithChildContext(codec, writer, value);}}private void writeMap(final BsonWriter writer, final MapString, Object map, final EncoderContext encoderContext) {writer.writeStartDocument();beforeFields(writer, encoderContext, map);for (final Map.EntryString, Object entry : map.entrySet()) {if (skipField(encoderContext, entry.getKey())) {continue;}writer.writeName(entry.getKey());writeValue(writer, encoderContext, entry.getValue());}writer.writeEndDocument();}private void writeIterable(final BsonWriter writer, final IterableObject list, final EncoderContext encoderContext) {writer.writeStartArray();for (final Object value : list) {writeValue(writer, encoderContext, value);}writer.writeEndArray();}private Object readValue(final BsonReader reader, final DecoderContext decoderContext) {BsonType bsonType reader.getCurrentBsonType();if (bsonType BsonType.NULL) {reader.readNull();return null;} else if (bsonType BsonType.ARRAY) {return readList(reader, decoderContext);} else if (bsonType BsonType.BINARY) {byte bsonSubType reader.peekBinarySubType();if (bsonSubType BsonBinarySubType.UUID_STANDARD.getValue() || bsonSubType BsonBinarySubType.UUID_LEGACY.getValue()) {return registry.get(UUID.class).decode(reader, decoderContext);}}return valueTransformer.transform(registry.get(bsonTypeClassMap.get(bsonType)).decode(reader, decoderContext));}private ListObject readList(final BsonReader reader, final DecoderContext decoderContext) {reader.readStartArray();ListObject list new ArrayListObject();while (reader.readBsonType() ! BsonType.END_OF_DOCUMENT) {list.add(readValue(reader, decoderContext));}reader.readEndArray();return list;}}3 MongoService:用于增删改查这里只用到了查询和插入方法
/*** Created by */
Service
public class MongoService {/*** 数据插入MongoDB初版* param Codec 用户将bson转化为Object的类* param musicInfos 需要存储的实体集合* param dbName 选择的db*///insertMongo(KeyEnum.TYPE_XIAMI.getKey(),keyword,resultContent);public void insertMongo(CollectibleCodec Codec,ListMusicInfo musicInfos,String dbName){String colName songlist;MongoUtil instance MongoUtil.instance;CodecRegistry registry CodecRegistries.fromCodecs(Codec);MongoDatabase database MongoUtil.instance.getDB(dbName);if(instance.getCollection(dbName, colName) null ){instance.createCollection(dbName, colName);}MongoCollectionMusicInfo music database.withCodecRegistry(registry).getCollection(colName, MusicInfo.class);musicInfos.forEach(item-{MusicInfo first music.find(item, MusicInfo.class).first();if(null ! first){return;}music.insertOne(item);});}public MongoService() {}/**** param Codec 用户将bson转化为Object的类* param musicInfo 封装查询条件的实体* param dbName 选择的db* return ListMusicInfo*/public ListMusicInfo getSongFromMongo(CollectibleCodec Codec,MusicInfo musicInfo,String dbName){String colName songlist;MongoUtil instance MongoUtil.instance;CodecRegistry registry CodecRegistries.fromCodecs(Codec);MongoDatabase database MongoUtil.instance.getDB(dbName);if(instance.getCollection(dbName, colName) null ){instance.createCollection(dbName, colName);}MongoCollectionMusicInfo music database.withCodecRegistry(registry).getCollection(colName, MusicInfo.class);ArrayListMusicInfo musicInfos new ArrayList();BlockMusicInfo block new BlockMusicInfo() {public void apply(MusicInfo t) {musicInfos.add(t);}};music.find(musicInfo,MusicInfo.class).forEach(block);return musicInfos;}public static void main(String[] args) {//查询
// ListMusicInfo musicInfoMongos new MongoService().getSongFromMongo(new MusicInfoCodec(), new MusicInfo(小幸运), music;
// for (int i 0; i musicInfoMongos.size(); i) {
// MusicInfo musicInfo musicInfoMongos.get(i);
// System.out.println(mongo__musicInfo.getName());
// }}
}(4) MongoUtil用于mongoClient 客户端的连接
package com.test.test.test.utils;import com.mongodb.BasicDBObject;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoClientOptions.Builder;
import com.mongodb.WriteConcern;
import com.mongodb.client.*;
import com.mongodb.client.model.Filters;
import com.mongodb.client.result.DeleteResult;
import org.bson.Document;
import org.bson.conversions.Bson;
import org.bson.types.ObjectId;import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;import static com.mongodb.client.model.Filters.*;
import static com.mongodb.client.model.Projections.*;
import static com.mongodb.client.model.Sorts.ascending;
/*** Created by .*/
public enum MongoUtil {/*** 定义一个枚举的元素它代表此类的一个实例*/instance;private static MongoClient mongoClient;static {System.out.println(MongoDBUtil初始化);String ip 127.0.0.1;int port 27017;instance.mongoClient new MongoClient(ip, port);// 大部分用户使用mongodb都在安全内网下但如果将mongodb设为安全验证模式就需要在客户端提供用户名和密码// boolean auth db.authenticate(myUserName, myPassword);Builder options new MongoClientOptions.Builder();options.cursorFinalizerEnabled(true);// options.autoConnectRetry(true);// 自动重连true// options.maxAutoConnectRetryTime(10); // the maximum auto connect retry timeoptions.connectionsPerHost(300);// 连接池设置为300个连接,默认为100options.connectTimeout(30000);// 连接超时推荐3000毫秒options.maxWaitTime(5000); //options.socketTimeout(0);// 套接字超时时间0无限制options.threadsAllowedToBlockForConnectionMultiplier(5000);// 线程队列数如果连接线程排满了队列就会抛出“Out of semaphores to get db”错误。options.writeConcern(WriteConcern.SAFE);//options.build();}// ------------------------------------共用方法---------------------------------------------------/*** 获取DB实例 - 指定DB** param dbName* return*/public MongoDatabase getDB(String dbName) {if (dbName ! null !.equals(dbName)) {MongoDatabase database mongoClient.getDatabase(dbName);return database;}return null;}//mongoDatabase.createCollection(test);public void createCollection(String dbName, String collName){try{mongoClient.getDatabase(dbName).createCollection(collName);}catch(Exception e){System.err.println(e.getClass().getName() : e.getMessage() );}}/*** 获取collection对象 - 指定Collection** param collName* return*/public MongoCollectionDocument getCollection(String dbName, String collName) {if (null collName || .equals(collName)) {return null;}if (null dbName || .equals(dbName)) {return null;}MongoCollectionDocument collection mongoClient.getDatabase(dbName).getCollection(collName);return collection;}/*** 查询DB下的所有表名*/public ListString getAllCollections(String dbName) {MongoIterableString colls getDB(dbName).listCollectionNames();ListString _list new ArrayListString();for (String s : colls) {_list.add(s);}return _list;}/*** 获取所有数据库名称列表** return*/public MongoIterableString getAllDBNames() {MongoIterableString s mongoClient.listDatabaseNames();return s;}/*** 删除一个数据库*/public void dropDB(String dbName) {getDB(dbName).drop();}/*** 查找对象 - 根据主键_id** param collection* param id* return*/public Document findById(MongoCollectionDocument collection, String id) {Document myDoc collection.find(Filters.eq(_id, id)).first();return myDoc;}/** 统计数 */public int getCount(MongoCollectionDocument coll) {int count (int) coll.count();return count;}/** 条件查询 */public MongoCursorDocument find(MongoCollectionDocument coll, Bson filter) {return coll.find(filter).iterator();}/** 分页查询 */public MongoCursorDocument findByPage(MongoCollectionDocument coll, Bson filter, int pageNo, int pageSize) {Bson orderBy new BasicDBObject(_id, 1);return coll.find(filter).sort(orderBy).skip((pageNo - 1) * pageSize).limit(pageSize).iterator();}/*** 通过ID删除** param coll* param id* return*/public int deleteById(MongoCollectionDocument coll, String id) {int count 0;ObjectId _id null;try {_id new ObjectId(id);} catch (Exception e) {return 0;}Bson filter Filters.eq(_id, _id);DeleteResult deleteResult coll.deleteOne(filter);count (int) deleteResult.getDeletedCount();return count;}/*** FIXME** param coll* param id* param newdoc* return*/public Document updateById(MongoCollectionDocument coll, String id, Document newdoc) {ObjectId _idobj null;try {_idobj new ObjectId(id);} catch (Exception e) {return null;}Bson filter Filters.eq(_id, _idobj);// coll.replaceOne(filter, newdoc); // 完全替代coll.updateOne(filter, new Document($set, newdoc));return newdoc;}public void dropCollection(String dbName, String collName) {getDB(dbName).getCollection(collName).drop();}/*** 关闭Mongodb*/public void close() {if (mongoClient ! null) {mongoClient.close();mongoClient null;}}/*** 测试入口** param args* throws CloneNotSupportedException*/public static void main(String[] args) {String dbName music;String collName songlist;MongoCollectionDocument coll MongoUtil.instance.getCollection(dbName, collName);ListIndexesIterableDocument list coll.listIndexes();//查询所有索引for (Document document : list) {System.out.println(---document.toJson());}}}
5 MongoService的使用
Autowired
private MongoService mongoService;public void insertMongo(){ListMusicInfo musicInfos new ArrayList();mongoService.insertMongo(new MusicInfoCodec(),monicInfos, music);
}
上一张成功的图最后安利一个mongodb的PC图形化客户端
Robo 3T
Robo 3T官网
