nodejs 操作gridfs

eddik

　　function exixtTest(Response) {
　　MongoClient.connect("mongodb://test:test@192.168.147.128:27017/test", function(err, db) {
　　var gs = new mongodb.GridStore(db, "hello.txt", "r");
　　gs.open(function(err, gs) {
　　mongodb.GridStore.exist(db, "/tmp/hello.txt", function(err, result) {
　　db.close();
　　console.log(err, result);
　　if (!err) {
　　Response.end("haha");
　　} else {
　　Response.end("err");
　　}
　　})
　　});
　　});
　　}
　　function createFileFromData(Response) {
　　MongoClient.connect("mongodb://test:test@192.168.147.128:27017/test", function(err, db) {
　　var gs = new mongodb.GridStore(db, new Date().getTime() + ".txt", "w", {
　　"content_type" : "text/explain",
　　"metadata" : {
　　"author" : "Daniel"
　　},
　　"chunk_size" : 1024 * 4
　　});
　　gs.open(function(err, gs) {
　　gs.write("hello world", function() {
　　gs.close(function(err) {
　　db.close();
　　if (!err) {
　　Response.end("success");
　　} else {
　　Response.end("fail");
　　}
　　});
　　});
　　});
　　});
　　}
　　function createFsFromFile(Response){
　　MongoClient.connect("mongodb://test:test@192.168.147.128:27017/test", function(err, db) {
　　var gs = new mongodb.GridStore(db, new Date().getTime() + ".mp3", "w", {
　　"content_type" : "stream/music",
　　"metadata" : {
　　"author" : "wangdonghua",
　　"originName":"光辉岁月.mp3"
　　},
　　"chunk_size" : 1024 * 4
　　});
　　gs.open(function(err, gs) {
　　gs.writeFile("d:/ghsy.mp3", function() {
　　gs.close(function(err) {
　　db.close();
　　if (!err) {
　　Response.end("success");
　　} else {
　　Response.end("fail");
　　}
　　});
　　});
　　});
　　});
　　}
　　function readDataFromGFS1(Response){
　　MongoClient.connect("mongodb://test:test@192.168.147.128:27017/test", function(err, db) {
　　var gs = new mongodb.GridStore(db, "1422689423998.mp3", "r");
　　gs.open(function(err, gs) {
　　gs.read(gs.length ,function(err,data){
　　/**
　　* gs.length - length of the file in bytes
　　gs.contentType - the content type for the file
　　gs.uploadDate - when the file was uploaded
　　gs.metadata - metadata that was saved with the file
　　gs.chunkSize - chunk size
　　* */
　　gs.close();
　　db.close();
　　if(!err){
　　Response.end(data);
　　}else{
　　Response.end("error");
　　}
　　});
　　});
　　});
　　}
　　function readDataFromGFS2(Response){
　　MongoClient.connect("mongodb://test:test@192.168.147.128:27017/test", function(err, db) {
　　var gs = new mongodb.GridStore(db, "1422689423998.mp3", "r");
　　gs.open(function(err, gs) {
　　var readStream = gs.stream(true);
　　readStream.pipe(Response);
　　readStream.on("error",function(){
　　gs.close();
　　db.close();
　　Response.end("read file error");
　　});
　　readStream.on("end",function(){
　　gs.close();
　　db.close();
　　Response.end();
　　});
　　});
　　});
　　}