java对所有mongodb表进行增删改查表名怎么设置

一、MongoDB数据库参数配置

1、推荐使用mongodb.cfg.properties配置，则在构造MongoDBService对象的时候只需调用无参构造方法即可自动完成配置。

2、如果没有通过mongodb.cfg.properties，会采用程序指定的默认配置。

// 定义默认配置，1、IP地址 2、端口号 3、用户名 4、密码 5、配置文件位置名 6、数据库名    private static final String MONGODB_ADDRESS = "127.0.0.1"    private static final int MONGODB_PORT = 27017    private static final String MONGODB_USERNAME = "root"    private static final String MONGODB_PASSWORD = ""    private static final String MONGODB_RESOURCE_FILE = "mongodb.cfg.properties"    private static final String MONGODB_DBNAME = "test"    private static final String MONGODB_COLLECTIONNAME = "test"

3、通过有参构造方法构造MongoDBService对象或通过get/set方法，指定数据库及集合，优先级最高。

//有参构造方法，指定数据库名与集合名    public MongoDBServiceImpl(String dbName, String collName) {        this.dbName = dbName        this.collName = collName        try {            db = getDb()        } catch (Throwable e) {            e.printStackTrace()        }    }    //无参构造方法，返回配置文件配置的数据库对象引用，如果配置文件中没有设置则返回默认数据库对象引用    public MongoDBServiceImpl() {        getDb()    }    /*     * 获取数据库对象，3种情况（优先级从高到低）：<span style="white-space: pre"></span>*1、构造方法指定2、配置文件指定3、默认数据库<span style="white-space: pre"></span>*（情况2、3在MongoDButil中设置）     */    public DB getDb() {        if (this.db == null) {            if (this.dbName == null) {                this.db = MongoDBUtil.getDB()            } else {                this.db = MongoDBUtil.getDBByName(this.dbName)            }        }        return this.db    }         /*     * 获取集合对象，3种情况（优先级从高到低）：         *1、构造方法指定2、配置文件指定3、默认数据库     *（情况2、3在MongoDButil中设置）     */    public DBCollection getCollection() {        if(this.collName != null){            return db.getCollection(this.collName)        }        else {            return MongoDBUtil.getDBCollection()        }    }

二、方法简介（具体实现参看MongoDBServiceImpl接口实现类）

1、获取基本信息或对象:

(1)、获取数据库名： getDbName()

(2)、设置数据库名（指定数据库）： setDbName(String dbName)

(3)、获取集合名： getCollName()

(4)、设置集合名（指定集合）： setCollName(String collName)

(5)、获取数据库对象： getDb()

2、数据插入方式：

(1)、插入单条数据： insert(DBObject obj)

(2)、插入多条数据： insertBatch(List list)void

3、数据删除方式：

(1)、删除单条数据： delete(DBObject obj)

(2)、删除多条数据： deleteBatch(List list)

4、数量统计方式：

(1)、获取集合中数据数量： getCollectionCount()

(2)、获取符合条件的数据数量： getCount(DBObject obj)

5、查找数据：

(1)、查找所有数据： findAll()

(2)、查找符合条件的数据： find(DBObject obj)

(3)、查找符合条件的数据并排序： find(DBObject query, DBObject sort)

(4)、查找符合条件的指定数量的数据并排序：find(DBObject query, DBObject sort, int start, int limit)

(5)、由ID查找数据： getById(String id)

6、更新数据 ：update(DBObject setFields, DBObject whereFields) void

7、打印List： printListDBObj(List list)

测试代码：（@Test）

public class testMongoService {    //使用mongodb.cfg.properties中配置的数据库与集合，如未指定，使用MongoDBUtil中默认的数据库与集合    MongoDBService mongoDBService1 = new MongoDBServiceImpl()         //测试插入数据    @Test    public void testInsert(){        //数据一，包括用户名、密码，地址信息（省份、城市），爱好[…]        BasicDBList dbList1 = new BasicDBList()        dbList1.add("basketball")        dbList1.add("music")        dbList1.add("web")        DBObject dbObject1 = new BasicDBObject("username","insert1")            .append("age", 18)            .append("address", new BasicDBObject("province","广东").append("city", "广州"))            .append("favourite", dbList1)        //数据二        BasicDBList dbList2 = new BasicDBList()        dbList2.add("football")        dbList2.add("music")        DBObject dbObject2 = new BasicDBObject("username","insert2")            .append("age", 18)            .append("address", new BasicDBObject("province","陕西").append("city", "西安"))            .append("favourite", dbList2)        //数据三        BasicDBList dbList3 = new BasicDBList()        dbList3.add("Linux")        DBObject dbObject3 = new BasicDBObject("username","insert3")            .append("age", 18)            .append("address", new BasicDBObject("province","河北").append("city", "保定"))            .append("favourite", dbList3)        //数据四        BasicDBList dbList4 = new BasicDBList()        dbList4.add("swim")        dbList4.add("android")        DBObject dbObject4 = new BasicDBObject("username","insert4")            .append("age", 18)            .append("address", new BasicDBObject("province","四川").append("city", "成都"))            .append("favourite", dbList4)        //数据五        DBObject dbObject5 = new BasicDBObject("username", "insert5")            .append("age", 28)            .append("address", new BasicDBObject("city", "杭州"))        mongoDBService1.printListDBObj(mongoDBService1.findAll())        System.out.println("——————————————————insert collection——————————————————")        List<dbobject>list = new ArrayList<dbobject>()        list.add(dbObject1)        list.add(dbObject2)        list.add(dbObject3)        list.add(dbObject5)        mongoDBService1.insertBatch(list)        System.out.println("——————————————————insert one——————————————————")        mongoDBService1.insert(dbObject4)        mongoDBService1.printListDBObj(mongoDBService1.findAll())    }         //测试查询数据    @Test    public void testFind(){        DBObject dbObject = new BasicDBObject("username","insert1")        System.out.println("数量：" + mongoDBService1.getCollectionCount())        System.out.println("username=java的数据数量：" + mongoDBService1.getCount(dbObject))        System.out.println("——————————————————find all——————————————————")        mongoDBService1.printListDBObj(mongoDBService1.findAll())        System.out.println("——————————————————find obj——————————————————")        mongoDBService1.printListDBObj(mongoDBService1.find(dbObject))        System.out.println("——————————————————find sort——————————————————")        mongoDBService1.printListDBObj(mongoDBService1.find(new BasicDBObject(), new BasicDBObject("age", 1)))        System.out.println("——————————————————find sort limit——————————————————")        mongoDBService1.printListDBObj(mongoDBService1.find(new BasicDBObject(), new BasicDBObject("age", 1), 1, 2))    }     //测试数据更新    @Test    public void testUpdate(){        BasicDBObject newDocument = new BasicDBObject("$set",new BasicDBObject("age",11))                         BasicDBObject searchQuery = new BasicDBObject().append("username", "insert2")             mongoDBService1.printListDBObj(mongoDBService1.find(searchQuery))        System.out.println("——————————————————update——————————————————")        mongoDBService1.update(newDocument, searchQuery)        mongoDBService1.printListDBObj(mongoDBService1.find(searchQuery))    }         //测试数据删除    @Test    public void testDelete(){        DBObject dbObject1 = new BasicDBObject("username", "insert1")        DBObject dbObject2 = new BasicDBObject("username", "insert2")        DBObject dbObject3 = new BasicDBObject("username", "insert3")        DBObject dbObject4 = new BasicDBObject("username", "insert4")        DBObject dbObject5 = new BasicDBObject("username", "insert5")        List<dbobject>list = new ArrayList<dbobject>()        list.add(dbObject1)        list.add(dbObject2)        list.add(dbObject3)        list.add(dbObject4)        mongoDBService1.printListDBObj(mongoDBService1.findAll())        System.out.println("——————————————————delete list——————————————————")        mongoDBService1.deleteBatch(list)        System.out.println("——————————————————delete one——————————————————")        mongoDBService1.delete(dbObject5)        //System.out.println("——————————————————delete all——————————————————")        //mongoDBService1.delete(new BasicDBObject())        mongoDBService1.printListDBObj(mongoDBService1.findAll())    }}</dbobject></dbobject></dbobject></dbobject>

测试结果：

源代码：（完整项目文件下载链接：点击打开链接）

MongoDBServiceImpl.java

public class MongoDBServiceImpl implements MongoDBService {    private String dbName    private String collName    private DB db         //有参构造方法，指定数据库名与集合名    public MongoDBServiceImpl(String dbName, String collName) {        this.dbName = dbName        this.collName = collName        try {            db = getDb()        } catch (Throwable e) {            e.printStackTrace()        }    }    //无参构造方法，返回配置文件配置的数据库对象引用，如果配置文件中没有设置则返回默认数据库对象引用    public MongoDBServiceImpl() {        getDb()    }    /*     * 获取数据库对象，3种情况（优先级从高到低）：     *1、构造方法指定2、配置文件指定3、默认数据库     *（情况2、3在MongoDButil中设置）     */    public DB getDb() {        if (this.db == null) {            if (this.dbName == null) {                this.db = MongoDBUtil.getDB()            } else {                this.db = MongoDBUtil.getDBByName(this.dbName)            }        }        return this.db    }         /*     * 获取集合对象，3种情况（优先级从高到低）：     *1、构造方法指定2、配置文件指定3、默认数据库     *（情况2、3在MongoDButil中设置）     */    public DBCollection getCollection() {        if(this.collName != null){            return db.getCollection(this.collName)        }        else {            return MongoDBUtil.getDBCollection()        }    }     public DBObject map2Obj(Map<string, object="">map) {        DBObject obj = new BasicDBObject()        if (map.containsKey("class") &&map.get("class") instanceof Class)            map.remove("class")        obj.putAll(map)        return obj    }    //插入数据    public void insert(DBObject obj) {        getCollection().insert(obj)    }    //插入多条数据    public void insertBatch(List<dbobject>list) {        if (list == null || list.isEmpty()) {            return        }        List<dbobject>listDB = new ArrayList<dbobject>()        for (int i = 0i <list.size()i++) {            listDB.add(list.get(i))        }        getCollection().insert(listDB)    }    //删除数据    public void delete(DBObject obj) {        getCollection().remove(obj)    }    //删除多条数据    public void deleteBatch(List<dbobject>list) {        if (list == null || list.isEmpty()) {            return        }        for (int i = 0i <list.size()i++) {            getCollection().remove(list.get(i))        }    }    //获取集合中的数据数量    public long getCollectionCount() {        return getCollection().getCount()    }    //查找符合条件的数据数量    public long getCount(DBObject obj) {        if (obj != null)            return getCollection().getCount(obj)        return getCollectionCount()    }    //查找符合条件的数据    public List<dbobject>find(DBObject obj) {        DBCursor cur = getCollection().find(obj)        return DBCursor2list(cur)    }         //查找符合条件的数据并排序    @Override    public List<dbobject>find(DBObject query, DBObject sort) {        DBCursor cur        if (query != null) {            cur = getCollection().find(query)        } else {            cur = getCollection().find()        }        if (sort != null) {            cur.sort(sort)        }        return DBCursor2list(cur)    }     //查找符合条件的数据并排序，规定数据个数    @Override    public List<dbobject>find(DBObject query, DBObject sort, int start,            int limit) {        DBCursor cur        if (query != null) {            cur = getCollection().find(query)        } else {            cur = getCollection().find()        }        if (sort != null) {            cur.sort(sort)        }        if (start == 0) {            cur.batchSize(limit)        } else {            cur.skip(start).limit(limit)        }        return DBCursor2list(cur)    }         //将DBCursor转化为list<dbobject>    private List<dbobject>DBCursor2list(DBCursor cur) {        List<dbobject>list = new ArrayList<dbobject>()        if (cur != null) {            list = cur.toArray()        }        return list    }     //更新数据    public void update(DBObject setFields, DBObject whereFields) {        getCollection().updateMulti(whereFields, setFields)    }    //查询集合中所有数据    public List<dbobject>findAll() {        DBCursor cur = getCollection().find()        List<dbobject>list = new ArrayList<dbobject>()        if (cur != null) {            list = cur.toArray()        }        return list    }     //由ID获取数据    public DBObject getById(String id) {        DBObject obj = new BasicDBObject()        obj.put("_id", new ObjectId(id))        DBObject result = getCollection().findOne(obj)        return result    }     public String getDbName() {        return dbName    }     public void setDbName(String dbName) {        this.dbName = dbName        this.db = MongoDBUtil.getDBByName(this.dbName)    }     public String getCollName() {        return collName    }     public void setCollName(String collName) {        this.collName = collName    }    @Override    public void printListDBObj(List<dbobject>list) {        // TODO Auto-generated method stub        for(DBObject dbObject: list){            System.out.println(dbObject)        }    }       }</dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></dbobject></string,>

MongoDBUtil.java

public class MongoDBUtil {    // 定义默认配置，1、IP地址 2、端口号 3、用户名 4、密码 5、配置文件位置名 6、数据库名    private static final String MONGODB_ADDRESS = "127.0.0.1"    private static final int MONGODB_PORT = 27017    private static final String MONGODB_USERNAME = "root"    private static final String MONGODB_PASSWORD = ""    private static final String MONGODB_RESOURCE_FILE = "mongodb.cfg.properties"    private static final String MONGODB_DBNAME = "test"    private static final String MONGODB_COLLECTIONNAME = "test"    // 定义静态变量，1、Mongo对象（代表数据库连接）2、DB对象（代表数据库）3、集合名4、数据库相关配置映射集合5、已获取的数据库连接    private static Mongo mongo    private static DB db    private static DBCollection collection    private static Map<string, string="">cfgMap = new HashMap<string, string="">()    private static Hashtable<string, db="">mongoDBs = new Hashtable<string, db="">()     /**     * 初始化Mongo的数据库     */    static {        init()    }     /**     * 获取配置文件中配置的DB对象     */    public static DB getDB() {        return db    }     /**     * 获取配置文件中配置的DBCollection对象     */    public static DBCollection getDBCollection() {        return collection    }     /**     * 根据数据库名称,得到数据库 如果不存在,则创建一个该名称的数据库,并设置用户名和密码为配置文件中的参数值     *     * @param dbName     * @return DB     */    @SuppressWarnings("deprecation")    public static DB getDBByName(String dbName) {        DB db = mongo.getDB(dbName)        if (!mongoDBs.contains(db)) {            System.out.println("add")            db.addUser(cfgMap.get("mongo.db.username"),                    cfgMap.get("mongo.db.password").toCharArray())            mongoDBs.put(dbName, db)        }        return db    }     // ————————————————————————————————————初始化过程————————————————————————————————————    /**     * 获取配置文件mongedb.cfg.properties的文件对象     */    public static File getConfigFile() {        String path = MongoDBUtil.class.getResource("/").getPath()        String fileName = path + MONGODB_RESOURCE_FILE        System.out.println(fileName)        File file = new File(fileName)        if (file.exists()) {            return file        }        return null    }     /**     * 通过mongedb.cfg.properties配置文件初始化配置映射集合，如果没有编写配置文件，则加载程序指定的默认配置     */    @SuppressWarnings("unchecked")    private static void initCfgMap() {        File file = getConfigFile()        if (file != null) {            Properties p = new Properties()            try {                p.load(new FileInputStream(file))                for (Enumeration enu = p.propertyNames()enu.hasMoreElements()) {                    String key = (String) enu.nextElement()                    String value = (String) p.getProperty(key)                    cfgMap.put(key, value)                }            } catch (IOException e) {                System.out.println("加载Mongo配置文件失败!")                e.printStackTrace()            }        } else { // 如果没有编写配置文件，则加载默认配置            cfgMap.put("mongo.db.address", MONGODB_ADDRESS)            cfgMap.put("mongo.db.port", String.valueOf(MONGODB_PORT))            cfgMap.put("mongo.db.username", MONGODB_USERNAME)            cfgMap.put("mongo.db.password", MONGODB_PASSWORD)            cfgMap.put("mongo.db.dbname", MONGODB_DBNAME)            cfgMap.put("mongo.db.collectionname", MONGODB_COLLECTIONNAME)        }    }     /**     * 初始化Mongo的数据库（将db指向相应对象引用，将collection指向相应对象引用，通过mongoDBs记录现有数据库对象）     */    @SuppressWarnings("deprecation")    private static void init() {        initCfgMap()        try {            String address = cfgMap.get("mongo.db.address")            int port = Integer.parseInt(cfgMap.get("mongo.db.port").toString())            String dbName = cfgMap.get("mongo.db.dbname")            String username = cfgMap.get("mongo.db.username")            String password = cfgMap.get("mongo.db.password")            String collectionName = cfgMap.get("mongo.db.collectionname")            mongo = new Mongo(address, port)            if (dbName != null &&!"".equals(dbName)) {                db = mongo.getDB(dbName)                if (username != null &&!"".equals(username)) {                    db.addUser(username, password.toCharArray())                    if (collectionName != null &&!"".equals(collectionName)) {                        collection = db.getCollection(collectionName)                    }                }                mongoDBs.put(dbName, db)            }        } catch (Exception e) {            e.printStackTrace()        }    } }

1、下载MongoDB数据库；

2、将安装文件解压到C盘（注意：安装路径中不能出现空格），配置“环境变量”，将 %MONGODB_HOME%in 添加到“Path”中；

3、进入DOS窗口，设置数据保存目录（与端口）和日志输出目录。

DOS命令：

mongod --port --dbpath --logpath --logappend --directoryperdb

参数说明：

--port 表示数据库端口，默认27017；

--dbpath 表示数据文件存储路径，一般设置为%MONGODB_HOME%data；

--logpath 表示日志文件存储路径，一般设置为%MONGODB_HOME%logsmongodb.log；

--logappend 表示日志追加，默认是覆盖；

--directoryperdb 表示每个db一个目录；

4、完成以上设置，MongoDB已经启动，新开启DOS窗口，执行“mongo.exe”，出现“MongoDB shell version: 1.8.1”表示安装成功了。

5、目前是以无权限限制的方式启动的，你可以做任何 *** 作。那么我们先切换到admin下，创建一个root用户吧。执行命令:

"use admin" ->"db.addUser("root","root")" ->"db.auth("root","root")"，如下图所示：

6、把MongoDB注册为Windows Service，让它开机自动启动；执行命令：

mongod --bind_ip 127.0.0.1 --logpath %MONGODB_HOME%logsmongodb.log --logappend --dbpath %MONGODB_HOME%data --directoryperdb --auth --install

注意：

a.必须切换到bin目录下执行该条指令。

b.必须添加--auth用户权限才会生效。

c.除了“--auth”和“--install”两个参数，别的参数要跟你设置用户时启动服务的参数一致，尤其是“--directoryperdb”。

第一次配置完成后，一定要重启才会有效果 重启mongo客户端，不输入-u-p可以直接进入，但是不具有任何权限。正确的访问方式为：mongo 数据库名 -u 用户名 -p。另外设置用户

7、服务安装成功后的界面：

8、如果安装失败：

删除MongoDB服务，执行命令：

sc delete MongoDB

启动MongoDB服务，执行命令：

net start "MongoDB"

9、在cmd下可有两种方法打开，net和sc，net用于打开没有被禁用的服务，语法是：

启动：net/sc start 服务名

停止：net/sc stop 服务名

10、另外，sc可用于打开被禁用的服务，语法是：

sc config 服务名 start= demand //手动

sc condig 服务名 start= auto //自动

sc config 服务名 start= disabled //禁用

注意：以上三个命令“=”号后面必须有一个空格

Mongo（也译芒果）名字来自humongous，意思是巨大无比的，极大的。它是一个高性能，开源，无模式的文档型NOSQL数据库。Mongo使用C++开发，提供了以下功能：

面向集合的存储：适合存储对象及JSON形式的数据。

动态查询：Mongo支持丰富的查询表达式。查询指令使用JSON形式的标记，可轻易查询文档中内嵌的对象及数组。

完整的索引支持：包括文档内嵌对象及数组。Mongo的查询优化器会分析查询表达式，并生成一个高效的查询计划。

查询监视：Mongo包含一个监视工具用于分析数据库 *** 作的性能。

复制及自动故障转移：Mongo数据库支持服务器之间的数据复制，支持主-从模式及服务器之间的相互复制。复制的主要目标是提供冗余及自动故障转移。

高效的传统存储方式：支持二进制数据及大型对象（如照片或图片）。

自动分片以支持云级别的伸缩性：自动分片功能支持水平的数据库集群，可动态添加额外的机器。

MongoDB服务端可运行在Linux、Windows或OS X平台，支持32位和64位应用，在32位模式运行时支持的最大文件尺寸为2GB。

常用启动参数：

–dbpath 指定特定存储目录启动，若目录不存在则创建。默认目录为/data/db。例：./mongod –dbpath /var/data/mongo

–port 指定端口启动。默认端口为27017。例：./mongod –port 12345

windows 下使用方法

直接启动：

$ bin/mongod.exe #启动服务器

$ bin/mongo.exe #启动客户端连接

注册为服务，这样以后开机就可以自动启动

$ bin/mongod.exe --logpath c:\data\log.log --logappend --dbpath "c:\data\db" --install #主要是install 参数，要新建c:\data\log.log文件和c:\data\db目录

删除服务

$ bin/mongod.exe --remove

当注册为服务时可以Win+R打开运行，输入services.msc来查看服务状态

常见错误

1、monge.exe客户端连接时报错：couldn’t connect to server 127.0.0.1 shell/mongo.js:79

这是因为monged.exe启动失败

2、多次尝试后monged.exe启动失败，始终没找到原因

这个错误困扰了我一段时间，后来发现c:\data\db下有个mongod.lock锁文件，把这个文件删除后，重新启动服务器就可以了。

服务启动报错: error2: system can not find the file specified.

solution:

安装服务的时候， 你需要用 mongod.exe的 full path

C:\mongodb-win32-i386-1.8.2\bin\mongod.exe --logpath c:\mongo

db\logs\mongo.log --dbpath c:\mongodb\data\db --directoryperdb --install

to remove service

C:\mongodb-win32-i386-1.8.2\bin\mongod.exe --logpath c:\mongo

db\logs\mongo.log --dbpath c:\mongodb\data\db --directoryperdb --remove

and re open windows service windows, the original service will gone.

<!--配置log对象-->

<bean id="logger" class="org.slf4j.LoggerFactory" factory-method="getLogger">

<constructor-arg type="java.lang.String" value=""></constructor-arg>

</bean>

<bean id="action_log" class="org.slf4j.LoggerFactory" factory-method="getLogger">

<constructor-arg type="java.lang.String" value="action_log"></constructor-arg>

</bean>

<bean id="service_log" class="org.slf4j.LoggerFactory" factory-method="getLogger">

<constructor-arg type="java.lang.String" value="service_log"></constructor-arg>

</bean>

<bean id="dao_log" class="org.slf4j.LoggerFactory" factory-method="getLogger">

<constructor-arg type="java.lang.String" value="dao_log"></constructor-arg>

</bean>

<bean id="job_log" class="org.slf4j.LoggerFactory" factory-method="getLogger">

<constructor-arg type="java.lang.String" value="job_log"></constructor-arg>

</bean>

---