BPM Tutorial: Thao tác với Database trên IBM BPM

Sau khi thiết lập kết nối được từ Database Oracle trên Websphere Application Server, đồng thời khai báo kết nối đó trong mục biến môi trường trong Process App (bài trước). Ta sẽ tiến hành tích hợp với các service BPM để thao tác với Database.

Xem bài viết gốc tại: https://viblo.asia/p/bpm-tutorial-thao-tac-voi-batabase-tren-ibm-bpm-djeZ1wX85Wz

Chuẩn bị:

• Coachview kèm với Business Object tương ứng
• Database và một bảng dữ liệu

Các bước tiến hành:

1. Chuẩn bị coachview, Clientside human service và Table Database

• Ví dụ: hình 1: Business Object hình 2: View hình 3: Lookup table

2. Khởi tạo Client Side Human Service

• Tạo CSHS, tạo variable, thêm vào trong coach View mà bạn đã tạo ở bước trên (lưu ý các bước này mình sẽ mặc định là các bạn đã biết làm, chi tiết cách xây dựng UI đơn giản đã nằm trong tutorial series trước đó https://viblo.asia/s/ibm-bpm-tutorial-RNZqg8gG50n

hình 4: CSHS flow và script khởi tạo (tránh lỗi null) hình 5: Thêm View Danh sách giao dịch

3. Tạo Service Flow để lấy dữ liệu

Bước 1: Khởi tạo

Bước 2: Chọn loại service

• Chọn từ palette một activity tên là Linked Service Flow, đổi tên thành SQL Execute Statement.
• Mục Implementation, phần Called service ta chọn Select rồi chọn SQL Execute Statement.

Bước 3: Thêm variable

Chuyển sang tab Variable, ta thêm một số biến Private:

• Bind hết các biến trên vào phần Input mapping của service SQL Execute Statement, trừ biến results bind vào Output Mapping.
• Thêm biến Output transaction Kiểu dữ liệu Transaction

Bước 4: Viết script chuẩn bị

• Kéo một Script Task từ Palette, đổi tên thành preparation, điền code sau:

tw.local.sql = 'SELECT * FROM DANH_SACH_GIAO_DICH WHERE LOAI_TIEN_CHUYEN = ?';
tw.local.returnType = 'Record';
tw.local.dataSourceName = tw.env.DATA_SOR_NAME;
tw.local.parameters = new tw.object.listOf.SQLParameter();
tw.local.parameters[0] = new tw.object.SQLParameter();
tw.local.parameters[0].mode = 'IN';
tw.local.parameters[0].type = 'VARCHAR';
tw.local.parameters[0].value = 'VND';

Giải thích:

Bước 5: Viết Script gán dữ liệu trả về

• Kéo một Script Task từ Palette, đổi tên thành mapping data, điền code sau:

tw.local.transaction = new tw.object.listOf.Transaction();
if (tw.local.results.length > 0){
	for (var i = 0; i < tw.local.results.length; i++){
		tw.local.transaction[i] = new tw.object.Transaction();
		tw.local.transaction[i].cusId = tw.local.results[i].ID_KHACH_HANG;
		tw.local.transaction[i].cusName = tw.local.results[i].TEN_NGUOI_HUONG;
		tw.local.transaction[i].caseId = tw.local.results[i].CASE_ID;
		tw.local.transaction[i].branchId = tw.local.results[i].MA_CHI_NHANH;
		tw.local.transaction[i].date = tw.local.results[i].NGAY_GIAO_DICH;
		tw.local.transaction[i].amount = tw.local.results[i].SO_TIEN_CHUYEN;
		tw.local.transaction[i].beneficiaryBank = tw.local.results[i].NGAN_HANG_HUONG;
		tw.local.transaction[i].currencyType = tw.local.results[i].LOAI_TIEN_CHUYEN;
		
	}
}

Bước 6: Test service

• Nhấn biểu tượng Debug ở góc màn hình:
• Bảng điều khiển bên phải màn hình, ta mở mục Data để xem dữ liệu đã thay đổi như thế nào. Tiếp đó ta nhấn nút Step Over để qua từng bước
• Kết thúc Debug, ta mở data của variable transaction ra nếu có dữ liệu như hình là được:

Bước 7: Gắn vào luồng CSHS

• Gắn service vào luồng như hình

• Binding output của service là biến của CSHS

• Nhấn Run để mở màn hình, nếu có kết quả như hình là được

Lưu ý:

• Có rất nhiều cách để xử lý kết quả trả về, không nhất thiết kiểu dữ liệu trả về (tw.local.returnType) phải là Record, nó có thể là XMLElement hoặc thậm chí một Business Object trực tiếp. Vấn đề ở đây nằm ở cách tiếp cận nào đơn giản cho mô hình dữ liệu của bạn đang có, bởi vì trong bài viết này, mình đã lựa chọn cách thông dụng và đơn giản nhất.
• Lỗi có thể xảy ra ở khắp mọi nơi, lưu ý luôn đọc kĩ và làm cẩn thận từng bước. Các bạn có thể đặt câu hỏi về lỗi tại mục comment.
• Đối với thêm, sửa, xóa, mình cảm thấy nó cũng đơn giản như select nên bài tiếp theo sẽ nói về thao tác với procedure, thêm sửa xóa DB các bạn tự vận động tư duy nha.