delete.js var nosql = require('..');Var lib = require('./lib.js');Var适配器= 'ndb';全球。mysql_conn_properties = {}; var user_args = []; // *** program starts here *** // analyze command line var usageMessage = "Usage: node delete message-id\n" + " -h or --help: print this message\n" + " -d or --debug: set the debug flag\n" + " --mysql_socket=value: set the mysql socket\n" + " --mysql_port=value: set the mysql port\n" + " --mysql_host=value: set the mysql host\n" + " --mysql_user=value: set the mysql user\n" + "--mysql_password=value: set the mysql password\n" + " --detail: set the detail debug flag\n" + " --adapter=: run on the named adapter (e.g. ndb or mysql)\n" ; // handle command line arguments var i, exit, val, values; for(i = 2; i < process.argv.length ; i++) { val = process.argv[i]; switch (val) { case '--debug': case '-d': unified_debug.on(); unified_debug.level_debug(); break; case '--detail': unified_debug.on(); unified_debug.level_detail(); break; case '--help': case '-h': exit = true; break; default: values = val.split('='); if (values.length === 2) { switch (values[0]) { case '--adapter': adapter = values[1]; break; case '--mysql_socket': mysql_conn_properties.mysql_socket = values[1]; break; case '--mysql_port': mysql_conn_properties.mysql_port = values[1]; break; case '--mysql_host': mysql_conn_properties.mysql_host = values[1]; break; case '--mysql_user': mysql_conn_properties.mysql_user = values[1]; break; case '--mysql_password': mysql_conn_properties.mysql_password = values[1]; break; default: console.log('Invalid option ' + val); exit = true; } } else { user_args.push(val); } } } if (user_args.length !== 1) { console.log(usageMessage); process.exit(0); }; if (exit) { console.log(usageMessage); process.exit(0); } console.log('Running delete with adapter', adapter, user_args); //create a database properties object var dbProperties = nosql.ConnectionProperties(adapter); // create a basic mapping var annotations = new nosql.TableMapping('tweet').applyToClass(lib.Tweet); // check results of delete var onDelete = function(err, object) { console.log('onDelete.'); if (err) { console.log(err); } else { console.log('Deleted: ' + JSON.stringify(object)); } process.exit(0); }; // delete an object var onSession = function(err, session) { if (err) { console.log('Error onSession.'); console.log(err); process.exit(0); } else { var tweet = new lib.Tweet(); tweet.id = user_args[0]; session.remove(tweet, onDelete, user_args[0]); } }; // connect to the database nosql.openSession(dbProperties, annotations, onSession);