如何删除MongoDB数据库中的文件

一、Insert *** 作

Insert *** 作是MongoDB插入数据的基本方法，对目标集合使用Insert *** 作，会将该文档添加到MongoDB并自动生成相应的ID键。文档结构采用类似JSON的BSON格式。常见的插入 *** 作主要有单条插入和批量插入两种形式。插入时只是简单地将文档存入数据库中，不进行额外的验证，也不会执行代码，所以不存在注入式攻击的可能。

1、单条插入

2、批量插入

MongoDB对批量插入的支持是通过传递多个文档组成的数组到数据库来实现的。由于它插入数据是通过发送TCP请求的，这样只需发送单个TCP请求，且数据库无需处理大量的消息头，减少插入时间。这种方式的批量插入一次只能将多个文档插入到一个集合中，对于插入到多个集合可以循环调用Insert *** 作。

二、Remove *** 作

remove函数可以用来删除数据，能接受一个文档作为可选参数，只有符合条件的文档才会被删除。删除数据是永久性的，不能撤销，也不能恢复，需要谨慎。删除文档需要清空整个集合，不如直接删除集合快。

三、Update *** 作

update函数用于修改数据库中的数据，接收两个参数，一个是查询文档，用来查找要更新的文档，另一个是修改器文档，用来描述对找到的文档做哪些修改。更新 *** 作是原子性的，如果多个更新同时发生，则所有的更新都会执行，但最后的更新是最终赢家。

1、整体更新（文档替换）

2、局部更新（修改器）

部分更新是通过原子的更新修改器实现的，使用修改器时除了”_id“的值不能改变，其他任何值都能改变。文档替换是可以改变所有值的。

$inc修改器：将指定属性的值增加特定的步长，如果键不存在则创建。

$set修改器：用来指定一个键的值，如果不存在则创建。

$push：数组修改器，如果指定的键存在，则向已有的数组末尾加入一个元素，键不存在则会创建一个新的数组。

3、upsert *** 作

upsert *** 作具有saveOrUpdate的功能，如果没有文档符合更新条件，则以更新条件和更新文档为基础创建一个新的文档。如果有符合更新条件的文档，则正常更新。创建新文档时会以条件文档作为基础，将修改器作用其之上。upsert *** 作是原子性的，高效的。

四、瞬间完成

上面的插入，删除和更新 *** 作都是瞬间完成的，不需要等待数据库响应。这样的实现可以获取高性能，速度非常快，只会受客户端发送速度和网络速度的制约。但由于不会获取服务器状态，所以不能保证 *** 作顺利完成。这对于付费系统，安全性较高的系统是不可行的，此时对这些 *** 作需要使用的安全版本。安全版本会在 *** 作执行后立即运行getLastError命令，来检查是否执行成功。如果失败一般会抛出可捕获的异常，然后可以在代码中处理。

一、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()        }    } }

原因是mongodb设计的本身机制问题造成的。

首先,mongodb在创建数据文件时，会根据64M,128M,256M...递增的方式产生数据文件，最大数据文件为2G，增大到2G之后，后面新增的数据文件都占用2G空间。

当删除某一个表的数据时，mongodb会标记你删除该表所在数据文件位置为：该部分的数据已经删除，但是不会释放该数据文件所占用的空间，当有新的数据进来之后，会将数据分配到该数据文件中。

一方面是：删除文件后不产生多余的数据碎片，

另一方面不做数据的大规模迁移，减少mongodb内部的IO *** 作。

所以在删除数据表之后，会发现系统空间并没有释放，从mongodb本身看，空间已经释放了，被删除数据的空间依然可用；

但从系统角度看，空间没有释放，并不会影响数据的存储。

---