2

我想拥有像关系或目标数据库这样的自动增量字段，所以我需要一个_id具有自动设置字段值的整数字段，值应该是最后一个记录_id值，如下所示：

数据：

{_id:1,name"foo"}
{_id:2,name"bar"}

删除最后一条记录：

{_id:1,name"foo"}

添加新记录：

{_id:1,name"foo"}
{_id:3,name"newbar"}

我在我的数据存储中添加了一个函数并计算 _id 和加 1 的最大值max(_id)+1并设置为字段值，但这里有问题：

当我们在关系数据库中使用自动增量字段时，它就像我说的那样工作，并且在您remove last record保留删除的记录号并且新插入的记录继续增加但以我的方式表示新记录的删除记录的 _id 之后。

我的代码是：

var Datastore = require('nedb'),
localDb = new Datastore({
    filename: __dirname + '/dbFilePath.db',
    autoload: true
});

localDb.getMax = function(fieldName, onFind){
   db.find({}).sort({_id:-1}).limit(1).exec(function (err, docs) {onFind && onFind(err, docs['_id']);});
   return localDb;
}

localDb.insertAutoId = function(data, onAdd){
    var newIndex = 0;
    localDb.getMax(function (err, maxValue) {
        newIndex = maxValue+1;

        if(!data["_id"])
            data["_id"] = newIndex;

        localDb.insert(data, function (err, newDoc) {
            onAdd && onAdd(err, newDoc);
        });
    });
    return localDb;
}
4

3 回答 3

5

nedb的改进答案是：

db.getAutoincrementId = function (cb) {
    this.update(
        { _id: '__autoid__' },
        { $inc: { seq: 1 } },
        { upsert: true, returnUpdatedDocs: true },
        function (err, affected, autoid) { 
            cb && cb(err, autoid.seq);
        }
    );
    return this;
};

这相当于mongodb的方式：

db.getAutoincrementId = function (cb) {
    this.findAndModify({
            query: { _id: '__autoid__' },
            update: { $inc: { seq: 1 } },
            new: true
        }
        function (err, autoid) { 
            cb && cb(err, autoid.seq);
        }
    );
    return this;
};
于 2016-11-14T14:34:22.223 回答
3

您可以将索引的最后一个值存储在数据库中。像这样的东西：

var Datastore = require('nedb');
var db = new Datastore({ 
  filename: __dirname + '/dbFilePath.db', 
  autoload: true 
});

// Initialize the initial index value
// (if it already exists in the database, it is not overwritten)
db.insert({_id: '__autoid__', value: -1});

db.getAutoId = function(onFind) {
  db.findOne( { _id: '__autoid__' }, function(err, doc) {
    if (err) {
      onFind && onFind(err)
    } else {
      // Update and returns the index value
      db.update({ _id: '__autoid__'}, { $set: {value: ++doc.value} }, {},
         function(err, count) {
           onFind && onFind(err, doc.value);
      });
    }
  });
  return db;
}
于 2016-05-29T10:27:17.763 回答
1

我不知道它是否对你有用 我使用数据库来存储下一个 id，灵感来自 mysql 系统。谁总是保留下一个id。所以我创建了一个函数来验证数据库是否有一个 id，如果没有，它会添加值“1”，当它更新时它会查找它是否存在并执行序列。这让我可以完全控制我的身份。架构将是：

{
name: nameDb,
nextId: itemID
}

如果您愿意，您可以创建用于更新文档、版本控制等的功能。

例子：

db.autoincrement = new Datastore({filename: 'data/autoincrement.db', autoload: true});

function getUniqueId(nameDb, cb) {
    db.autoincrement.findOne({name: nameDb}, function (err, doc) {
        if (err) {
            throw err;
        } else {
            if (doc) {
                const itemID = doc.nextId + 1;
                db.autoincrement.update({name: nameDb}, {
                    name: nameDb,
                    nextId: itemID
                }, {}, function (err, numReplaced) {
                    db.autoincrement.persistence.compactDatafile();
                    if (err) {
                        throw err;
                    } else {
                        // console.log(numReplaced);
                    }
                    cb(doc.nextId);
                });
            } else {
                const data = {
                    name: nameDb,
                    nextId: 2
                };

                db.autoincrement.insert(data, function (err, newDoc) {
                    if (err) {
                        throw err;
                    } else {
                        // console.log(newDoc);
                    }
                    cb(1);
                });
            }
        }

    });
}

插入新文档示例：

       function insert(req, cb) {
        getUniqueId("testdb", function (uniqueId) {
            data.itemId = uniqueId;

            db.testdb.insert(data, function (err, newDoc) {
                if (err) {
                    cb({error: '1', message: 'error#2'});
                    throw err;
                }
                cb({error: '0', message: 'Item add'});
            });

        });
       }
于 2017-03-05T15:28:20.277 回答