npm install [email protected]

{
	"dev": {
		"chat": {
			"type": "mongo",
			"host": "***",
			"port": 27017,
			"userName": "***",
			"password": "***",
			"database": "wechat"
		},
		"test1": {
			"type": "mysql",
			"host": "***",
			"port": 3306,
			"userName": "***",
			"password": "***",
			"database": "test1"
		}
	},
}

// 引入依赖
let fix = require('asgc-data-fix');

/**
 * 启动过脚本
 * 1、第一个参数dev代表脚本执行环境为"dev"，对应于配置文件中的dev部分
 * 2、第二个参数是一个数组，数组前面几个参数代表需要的dev环境中的test1、chat实例，这里是mysql、mongo连接实例
 * 3、数组最后一个参数是一个回调函数，是用户脚本的执行入口，回调函数的参数即前面声明的test1、chat实例
 * 4、函数的async修饰根据需要使用，不需要时可以不写，此处需要配合await做异步转同步
 * 5、会调函数执行开始前，框架会自动初始化服务实例（如打开数据库连接）。执行完毕后，框架会自动关闭服务实例（如关闭数据库连接）。
 */
fix.startup('dev', ['test1', 'chat', async function(test1DB, chatDB){

	console.log('==========================mysql操作示例==========================');
	// 新增
	let insertResult = await test1DB.execute(`
			insert into stu(id,name) values 
			(1, '张三'),
			(2, '李四'),
			(3, '王五')
		`);
	console.log('insertResult', insertResult);
	// 查询列表
	console.log('list', await test1DB.find(`select * from stu`));
	// 更新
	await test1DB.execute(`
		update stu set name = '张三111' where id = 1
		`);
	// 查询单条
	console.log('stu', await test1DB.findOne(`select * from stu where id = 1`));
	// 删除
	let deleteResult = await test1DB.execute(`delete from stu`);
	console.log('deleteResult', deleteResult);

	console.log('==========================mongo操作示例==========================');
	// 新增
	let insertWeChatInfoResult = await chatDB.insertOne('WeChatInfo', {
		_id:'weChatId1',
		weChatId: 'wxid_trufcrgkcnwr22',
		nickName: '自相矛盾'
	});
	console.log('insertWeChatInfoResult', insertWeChatInfoResult.result);
	// 查询
	let weChatInfoList = await chatDB.find('WeChatInfo', {});
	console.log('weChatInfoList', weChatInfoList);
	// 删除
	await chatDB.delete('WeChatInfo');

}]);

load config finished.
load plugins finished. [ 'mongo', 'mysql' ]
======================脚本执行开始
默认环境: dev
======================服务：test1开启成功！
======================服务：chat开启成功！
==========================mysql操作示例==========================
insertResult OkPacket {
  fieldCount: 0,
  affectedRows: 3,
  insertId: 3,
  serverStatus: 2,
  warningCount: 0,
  message: '&Records: 3  Duplicates: 0  Warnings: 0',
  protocol41: true,
  changedRows: 0
}
list [
  RowDataPacket { id: 1, name: '张三' },
  RowDataPacket { id: 2, name: '李四' },
  RowDataPacket { id: 3, name: '王五' }
]
stu RowDataPacket { id: 1, name: '张三111' }
deleteResult OkPacket {
  fieldCount: 0,
  affectedRows: 3,
  insertId: 0,
  serverStatus: 34,
  warningCount: 0,
  message: '',
  protocol41: true,
  changedRows: 0
}
==========================mongo操作示例==========================
insertWeChatInfoResult { n: 1, ok: 1 }
weChatInfoList [
  {
    _id: 'weChatId1',
    weChatId: 'wxid_trufcrgkcnwr22',
    nickName: '自相矛盾'
  }
]
======================服务：test1关闭.
======================服务：chat关闭.
======================脚本执行结束

{
	// 环境配置
	"dev": {
		// 实例配置
		"test1": {
			"type": "mysql",
			"host": "***",
			"port": 3306,
			"userName": "***",
			"password": "***",
			"database": "test1"
		},
		"chat": {
			"type": "mongo",
			"host": "***",
			"port": 27017,
			"userName": "***",
			"password": "***",
			"database": "test1"
		}
	},
	"uat": {

	}
}

fix.startup('dev', ['test1',async function(test1DB){

}]);

fix.startup(['dev:test1','uat:chat',async function(test1DB){

}]);

--|plugins
	--|myplugin
		--|index.js

class MyPlugin {
	constructor(options) {
		console.log('MyPlugin create...', options);
		this.name = options.name || '';
	}
	open(){
		console.log('MyPlugin open...');
	}
	close(){
		console.log('MyPlugin close...');
	}
	say(msg){
		console.log(`MyPlugin sayHello ${this.name} ${msg}`);
	}
}

module.exports = {
	create: function(options) {
		return new MyPlugin(options);
	}
}

fix.startup('dev', ['customer', 'employee', async function(customerDB, employeeDB){
	// TODO
}]);

fix.startup(['pro:customer', 'uat:customer', async function(proCustomerDB, uatEmployeeDB){
	// TODO
}]);