主頁 > 資料庫 > 作業流第六章之用戶組與用戶

作業流第六章之用戶組與用戶

2021-01-03 10:51:14 資料庫

某些企業會將相同職能的人作為一類人進行管理，也會有某些企業，將相同的角色（職能不同）作為一類人進行管理，這些類別就是本章所說的用戶組，Activiti中用戶組對應的表為ACT_ID_GROUP，該表只有4個欄位，
Group物件
Group是一個介面，一個Group實體表示一條用戶組資料，對應的表為ACT_ID_GROUP，該介面只提供了相應欄位的getter和setter方法，這種資料與物件的映射關系，在各個ORM框架中使用很普遍，例如Hibernate、MyBatis等，
GroupEntity中包含以下映射屬性，
? id：主鍵，對應ACT_ID_GROUP表的ID_列，
? name：用戶組名稱，對應ACT_ID_GROUP表的NAME_列，
? type：用戶組型別，對應ACT_ID_GROUP表的TYPE_列，
? revision：該用戶組資料的版本，對應ACT_ID_GROUP表的REV_列，

添加用戶

package org.crazyit.activiti;

import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;

/**
 * 添加用戶組
 * @author yangenxiong
 *
 */
public class AddGroup {

	public static void main(String[] args) {
		// 創建默認的流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 生成UUID
		String genId = UUID.randomUUID().toString();
		//呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(genId);
		group.setName("經理組");
		group.setType("manager");
		//保存Group到資料庫
		identityService.saveGroup(group);
		// 查詢用戶組
		Group data = identityService.createGroupQuery().groupId(genId).singleResult();
		// 保存后查詢Group
		System.out.println("Group ID：" + data.getId() + ", Name：" + data.getName());
//		// 設定名稱 
//		data.setName("經理2組");
//		identityService.saveGroup(data);
//		// 再次查詢
//		data = identityService.createGroupQuery().groupId(genId).singleResult();
//		System.out.println("Group ID：" + data.getId() + ", Name：" + data.getName());
	}
}

洗掉用戶

package org.crazyit.activiti;

import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;

/**
 * 添加用戶組
 * 
 * @author yangenxiong
 * 
 */
public class DeleteGroup {

	public static void main(String[] args) {
		// 創建默認的流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		String genId = UUID.randomUUID().toString();
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(genId);
		group.setName("經理組");
		group.setType("manager");
		// 保存Group到資料庫
		identityService.saveGroup(group);
		// 查詢用戶組
		System.out.println("保存后用戶組數量："
				+ identityService.createGroupQuery().count());
		// 根據ID洗掉用戶組
		identityService.deleteGroup(genId);
		System.out.println("洗掉后用戶組數量："
				+ identityService.createGroupQuery().count());
	}
}

Activiti資料查詢

Activiti提供了一套資料查詢API提供給開發者使用，可以使用各個服務組件的createXXXQuery方法來獲取這些查詢物件，
查詢物件
Activiti的各個服務組件（XXXService）均提供了createXXXQuery方法，例如IdentityService中的createGroupQuery方法和createUserQuery方法，TaskService中的craeteTaskQuery方法等，這些方法回傳一個Query實體，例如createGroupQuery回傳GroupQuery，GroupQuery是Query的子介面，

Query是所有查詢物件的父介面，該介面中定義了若干個基礎方法，各個查詢物件均可以使用這些公共方法，包括設定排序方式、資料量統計（count）、串列、分頁和唯一記錄查詢，這些方法描述如下，
? asc：設定查詢結果的排序方式為升序，
? count：計算查詢結果的資料量，
? desc：設定查詢結果的排序方式為降序，
? list：封裝查詢結果，回傳相應型別的集合，
? listPage：分頁回傳查詢結果，
? singleResult：查詢單條符合條件的資料，如果查詢不到，則回傳 null；如果查詢到多條記錄，則拋出例外，

List方法
Query介面的list方法，將查詢物件對應的物體資料以集合形式回傳，對于回傳的集合要指定特定的元素型別，如果沒有查詢條件，則會將表中的全部的資料查出，默認按照主鍵升序排序，
創建activiti.cfg.xml組態檔

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans   http://www.springframework.org/schema/beans/spring-beans.xsd">

	<bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
		<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/act" />
		<property name="jdbcDriver" value="com.mysql.jdbc.Driver" />
		<property name="jdbcUsername" value="root" />
		<property name="jdbcPassword" value="root" />
		<property name="databaseSchemaUpdate" value="true"/>
	</bean>

</beans>

創建log4j.properties組態檔

# Set root category priority to INFO and its only appender to CONSOLE.
log4j.rootCategory=INFO, CONSOLE
#log4j.rootCategory=INFO, CONSOLE, LOGFILE

# Set the enterprise logger category to FATAL and its only appender to CONSOLE.
log4j.logger.org.apache.axis.enterprise=FATAL, CONSOLE

# CONSOLE is set to be a ConsoleAppender using a PatternLayout.
log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1} - %m%n

log4j.logger.org.apache=INFO
log4j.logger.org.htmlparser=INFO
log4j.logger.org.htmlparser=INFO
log4j.logger.org.crazyit=DEBUG
log4j.logger.org.drools=DEBUG
log4j.logger.org.mule=ERROR
log4j.logger.org.springframework=ERROR

測驗

package org.crazyit.activiti;

import java.util.List;
import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;

/**
 * 使用Query的list方法
 * 
 * @author yangenxiong
 * 
 */
public class ListData {

	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();		
		// 寫入5條用戶組資料
		createGroup(identityService, "1", "GroupA", "typeA");
		createGroup(identityService, "2", "GroupB", "typeB");
		createGroup(identityService, "3", "GroupC", "typeC");
		createGroup(identityService, "4", "GroupD", "typeD");
		createGroup(identityService, "5", "GroupE", "typeE");
		// 使用list方法查詢全部的部署資料
		List<Group> datas = identityService.createGroupQuery().list();
		for (Group data : datas) {
			System.out.println(data.getId() + "---" + data.getName() + " ");
		}
	}

	// 將用戶組資料保存到資料庫中
	static void createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
	}

}

listPage方法與list方法類似，最終也是以主鍵升序排序回傳結果集，與list方法不一樣的是，listPage方法需要提供兩個int引數，第一個引數為資料的開始索引，從0開始，第二個引數為結果數量，不難看出，該方法適用于分頁查詢，

package org.crazyit.activiti;

import java.util.List;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;

/**
 * 使用Query的listPage方法
 * @author yangenxiong
 *
 */
public class ListPage {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		//創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 寫入5條用戶組資料
		createGroup(identityService, "1", "GroupA", "typeA");
		createGroup(identityService, "2", "GroupB", "typeB");
		createGroup(identityService, "3", "GroupC", "typeC");
		createGroup(identityService, "4", "GroupD", "typeD");
		createGroup(identityService, "5", "GroupE", "typeE");
		//呼叫listPage方法，從索引為2的記錄開始，查詢3條記錄
		List<Group> datas = identityService.createGroupQuery().listPage(2, 3);
		for (Group data : datas) {
			System.out.println(data.getId() + "---" + data.getName() + " ");
		}
	}
	
	// 將用戶組資料保存到資料庫中
	static void createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
	}
}

22:44:25,328  INFO DbSqlSession - performing create on identity with resource org/activiti/db/create/activiti.mysql.create.identity.sql
22:44:25,329  INFO DbSqlSession - Found MySQL: majorVersion=5 minorVersion=7
22:44:25,449  INFO ProcessEngineImpl - ProcessEngine default created
22:44:25,483  INFO ProcessEngines - initialised process engine default
3---GroupC 
4---GroupD 
5---GroupE

count方法
該方法用于計算查詢結果的資料量，類似于SQL中的SELECT COUNT陳述句，如果不加任何條件，將會統計整個表的資料量，

package org.crazyit.activiti;

import java.util.List;
import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;

/**
 * 使用Query的count方法
 * 
 * @author yangenxiong
 * 
 */
public class Count {

	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 寫入5條用戶組資料
		createGroup(identityService, UUID.randomUUID().toString(), "GroupA", "typeA");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupB", "typeB");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupC", "typeC");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupD", "typeD");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupE", "typeE");
		// 使用list方法查詢全部的部署資料
		long size = identityService.createGroupQuery().count();
		System.out.println("Group 數量：" + size);
	}

	// 將用戶組資料保存到資料庫中
	static void createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
	}
}

排序方法
Query中提供了asc和desc方法，使用這兩個方法可以設定查詢結果的排序方式，但是呼叫這兩個方法的前提是，必須告訴Query物件，按何種條件進行排序，例如要按照ID排序，就要呼叫相應查詢物件的orderByXXX方法，或者GroupQuery的orderByGroupId、orderByGroupName等方法，如果不呼叫這些方法而直接使用asc或者desc方法，則會拋出ActivitiException，例外資訊為：You should call any of the orderBy methods first before specifying a direction，要求Activiti進行排序，卻不告訴它以哪個欄位進行排序，因此會拋出例外，

package org.crazyit.activiti;

import java.util.List;
import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;

/**
 * Query的排序
 * @author yangenxiong
 *
 */
public class Sort {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		//創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 寫入5條用戶組資料
		createGroup(identityService, UUID.randomUUID().toString(), "1", "typeA");
		createGroup(identityService, UUID.randomUUID().toString(), "2", "typeB");
		createGroup(identityService, UUID.randomUUID().toString(), "3", "typeC");
		createGroup(identityService, UUID.randomUUID().toString(), "4", "typeD");
		createGroup(identityService, UUID.randomUUID().toString(), "5", "typeE");
		//呼叫orderByGroupId和asc方法，結果為按照ID升序排序
		System.out.println("asc排序結果：");
		List<Group> datas = identityService.createGroupQuery().orderByGroupName().asc().list();
		for (Group data : datas) {
			System.out.println("    " + data.getId() + "---" + data.getName());
		}
		System.out.println("desc排序結果");
		//呼叫orderByGroupName和desc方法，結果為名稱降序排序
		datas = identityService.createGroupQuery().orderByGroupName().desc().list();
		for (Group data : datas) {
			System.out.println("    " + data.getId() + "---" + data.getName());
		}
	}
	
	// 將用戶組資料保存到資料庫中
	static void createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
	}

}

ID排序問題
在Activiti的設計中，每個資料表的主鍵均被設定為字符型，這樣的設計使得Activiti各個資料表的主鍵可以被靈活設定，但是如果使用數字字串作為其主鍵，那么按照ID排序

package org.crazyit.activiti;

import java.util.List;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;

/**
 * Query的的排序問題
 * @author yangenxiong
 *
 */
public class SortProblem {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		//創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 寫入5條用戶組資料
		createGroup(identityService, "1", "GroupA", "typeA");
		createGroup(identityService, "12", "GroupB", "typeB");
		createGroup(identityService, "13", "GroupC", "typeC");
		createGroup(identityService, "2", "GroupD", "typeD");
		createGroup(identityService, "3", "GroupE", "typeE");
		//根據ID升序排序
		System.out.println("asc排序結果");
		List<Group> datas = identityService.createGroupQuery().orderByGroupId().asc().list();
		for (Group data : datas) {
			System.out.print(data.getId() + " ");
		}
	}

	// 將用戶組資料保存到資料庫中
	static void createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
	}
}

多欄位排序
在進行資料查詢時，如果想對多個欄位進行排序，例如按名稱降序、ID升序排序，那么在呼叫asc和desc方法時就需要注意，asc和desc方法會根據Query實體（AbstractQuery）中的orderProperty屬性來決定排序的欄位，由于orderProperty是AbstractQuery的類屬性，因此在第二次呼叫orderByXXX方法后，會覆寫第一次呼叫時所設定的值，

package org.crazyit.activiti;

import java.util.List;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;

/**
 * Query的多欄位排序
 * @author yangenxiong
 *
 */
public class SortMix {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		//創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 寫入5條用戶組資料
		createGroup(identityService, "1", "GroupE", "typeB");
		createGroup(identityService, "2", "GroupD", "typeC");
		createGroup(identityService, "3", "GroupC", "typeD");
		createGroup(identityService, "4", "GroupB", "typeE");
		createGroup(identityService, "5", "GroupA", "typeA");
		//優先按照id降序、名稱升序排序
		System.out.println("ID降序排序：");
		List<Group> datas = identityService.createGroupQuery()
				.orderByGroupId().desc()
				.orderByGroupName().asc().list();
		for (Group data : datas) {
			System.out.println("    " + data.getId() + "---" + data.getName() + " ");
		}
		System.out.println("名稱降序排序：");
		//下面結果將按名稱排序
		datas = identityService.createGroupQuery().orderByGroupId()
				.orderByGroupName().desc().list();
		for (Group data : datas) {
			System.out.println("    " + data.getId() + "---" + data.getName() + " ");
		}
	}

	// 將用戶組資料保存到資料庫中
	static void createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
	}
}

singleResult方法
該方法根據查詢條件，到資料庫中查詢唯一的資料記錄，如果沒有找到符合條件的資料，則回傳null，如果找到多于一條的記錄，則拋出例外，例外資訊為：Query return 2 results instead of max 1，代碼清單6-10為一個使用singleResult方法的示例，并且體現三種查詢結果

package org.crazyit.activiti;

import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.identity.Group;
import org.activiti.engine.repository.Deployment;

/**
 * 使用Query的singleResult方法
 * @author yangenxiong
 *
 */
public class SingleResult {

	public static void main(String[] args) {
		//創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 寫入5條用戶組資料
		createGroup(identityService, UUID.randomUUID().toString(), "GroupA", "typeA");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupB", "typeB");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupC", "typeC");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupD", "typeD");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupE", "typeE");
		//再寫入一條名稱為GroupA的資料
		createGroup(identityService, UUID.randomUUID().toString(), "GroupA", "typeF");
		//查詢名稱為GroupB的記錄
		Group groupB = identityService.createGroupQuery()
				.groupName("GroupB").singleResult();
		System.out.println("查詢到一條GroupB資料：" + groupB.getId() + "---" + groupB.getName());
		//查詢名稱為GroupF的記錄
		Group groupF = identityService.createGroupQuery()
				.groupName("GroupF").singleResult();
		System.out.println("沒有groupF的資料：" + groupF);
		//查詢名稱為GroupA的記錄，這里將拋出例外
		Group groupA = identityService.createGroupQuery()
				.groupName("GroupA").singleResult();
	}

	// 將用戶組資料保存到資料庫中
	static void createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
	}
}

用戶組資料查詢
在前面幾節中，以用戶組資料為基礎，講解了Activiti的資料查詢機制以及一些公用的查詢方法，Activiti的每種資料均有對應的查詢物件，例如用戶組的查詢物件為GroupQuery，它繼承了AbstractQuery，除了擁有基類的方法（asc、count、desc、list、ListPage及singleResult方法）外，它還擁有自己的查詢及排序方法，
? groupId（String groupId）：根據ID查詢與引數值一致的記錄，
? groupMember（String groupMemberUserId）：根據用戶ID查詢用戶所在的用戶組，用戶組與用戶為多對多關系，因此一個用戶有可能屬于多個用戶組，
? groupName（String groupName）：根據用戶組名稱查詢用戶組，
? groupNameLike（String groupName）：根據用戶組名稱模糊查詢用戶組資料，
? groupType（String groupType）：根據用戶組型別查詢用戶組資料，
? orderByGroupId（）：設定排序條件為根據ID排序，
? orderByGroupName（）：設定排序條件為根據名稱排序，
? orderByGroupType（）：設定排序條件為根據型別排序，
? potentialStarter（String procDefId）：根據流程定義的ID查詢有權限啟動該流程定義的用戶組，

package org.crazyit.activiti;

import java.util.List;
import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;

/**
 * 
 * @author yangenxiong
 *
 */
public class GroupQuery {

	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 寫入5條用戶組資料
		String aId = UUID.randomUUID().toString();
		createGroup(identityService, aId, "GroupA", "typeA");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupB", "typeB");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupC", "typeC");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupD", "typeD");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupE", "typeE");
		// groupId方法
		Group groupA = identityService.createGroupQuery().groupId(aId).singleResult();
		System.out.println("groupId method: " + groupA.getId());
		// groupName方法
		Group groupB = identityService.createGroupQuery().groupName("GroupB").singleResult();
		System.out.println("groupName method: " + groupB.getName());
		// groupType方法
		Group groupC = identityService.createGroupQuery().groupType("typeC").singleResult();
		System.out.println("groupType method: " + groupC.getName());
		// groupNameLike方法
		List<Group> groups = identityService.createGroupQuery().groupNameLike("%group%").list();
		System.out.println("groupNameLike method: " + groups.size());
	}

	// 將用戶組資料保存到資料庫中
	static void createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
	}
}

原生SQL查詢
在各個服務組件中，都提供了createNativeXXXQuery方法，該方法回傳NativeXXXQuery的實體，這些物件均是NativeQuery的子介面，使用NativeQuery的方法，可以傳入原生的SQL進行資料查詢，主要使用sql方法傳入SQL陳述句，使用parameter方法設定查詢引數，

package org.crazyit.activiti;

import java.util.List;
import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;

/**
 * 使用NativeQuery
 * 
 * @author yangenxiong
 * 
 */
public class NativeQueryTest {

	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 寫入5條用戶組資料
		createGroup(identityService, UUID.randomUUID().toString(), "GroupA",
				"typeA");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupB",
				"typeB");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupC",
				"typeC");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupD",
				"typeD");
		createGroup(identityService, UUID.randomUUID().toString(), "GroupE",
				"typeE");
		// 使用原生SQL查詢全部資料
		List<Group> groups = identityService.createNativeGroupQuery()
				.sql("select * from ACT_ID_GROUP").list();
		System.out.println("查詢全部資料：" + groups.size());
		// 使用原生SQL按條件查詢，并設入引數，只查到一條資料
		groups = identityService.createNativeGroupQuery()
				.sql("select * from ACT_ID_GROUP where NAME_ = 'GroupC'")
				.list();
		System.out.println("按條件查詢：" + groups.get(0).getName());
		// 使用parameter方法設定查詢引數
		groups = identityService.createNativeGroupQuery()
				.sql("select * from ACT_ID_GROUP where NAME_ = #{name}")
				.parameter("name", "GroupD").list();
		System.out.println("使用parameter方法按條件查詢：" + groups.get(0).getName());
	}

	// 將用戶組資料保存到資料庫中
	static void createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
	}

}

用戶管理
作為流程基本元素之一，Activiti同樣為用戶資料提供了一套管理的API，用戶資料保存在ACT_ID_USER表中，除了該表外，Activiti還提供了ACT_ID_INFO表用于保存用戶資訊資料
User物件
與Group物件一樣，User物件同樣為一個介面，其有一個子介面UserEntity，實作類為UserEntityImpl，UserEntityImpl包含以下映射屬性，
? id：用戶ID，對應ACT_ID_USER表的ID_列，
? firstName：用戶的姓，對應ACT_ID_USER表的FIRST_列，
? lastName：用戶的名，對應ACT_ID_USER表的LAST_列，
? email：用戶郵箱，對應ACT_ID_USER表的EMAIL_列，
? password：用戶密碼，對應ACT_ID_USER表的PWD_列，
? pictureByteArrayId：用戶圖片的資料記錄ID，對應ACT_ID_USER表的PICTURE_ID_列，該列保存ACT_GE_BYTEARRAY表資料的ID，
? revision：該用戶資料的版本，對應ACT_ID_USER表的REV_列，
在API檔案中，只能看到User介面的方法，revision欄位并不讓外部操作與獲取，
添加用戶
添加用戶與創建用戶組類似，Activiti也提供了一個創建User實體的方法（newUser），還提供了一個保存用戶資料的方法（saveUser），類似于用戶組的newGroup與saveGroup方法，
添加用戶

package org.crazyit.activiti;

import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.User;

/**
 * 添加用戶
 * @author yangenxiong
 *
 */
public class AddUser {

	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		String id = UUID.randomUUID().toString();
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName("Angus");
		user.setLastName("Young");
		user.setEmail("yangenxiong@163.com");
		user.setPassword("abc");
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
		// 根據 id 查詢
		user = identityService.createUserQuery().userId(id).singleResult();
		System.out.println(user.getEmail());
	}

}

修改用戶

package org.crazyit.activiti;

import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.User;

/**
 * 修改用戶
 * @author yangenxiong
 *
 */
public class UpdateUser {

	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();		
		String id = UUID.randomUUID().toString();
		// 創建用戶
		creatUser(identityService, id, "angus", "young", "yangenxiong@163.com", "abc");
		// 查詢用戶
		User user = identityService.createUserQuery().userId(id).singleResult();
		user.setEmail("abc@163.com");
		// 執行保存
		identityService.saveUser(user);
	}
	
	//創建用戶方法
	static void creatUser(IdentityService identityService, String id, String first, String last, String email, String passwd) {
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName(first);
		user.setLastName(last);
		user.setEmail(email);
		user.setPassword(passwd);
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
	}

}

洗掉用戶

package org.crazyit.activiti;

import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.User;

/**
 * 洗掉用戶
 * @author yangenxiong
 *
 */
public class DeleteUser {

	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		String id = UUID.randomUUID().toString();
		// 創建用戶
		creatUser(identityService, id, "angus", "young", "yangenxiong@163.com", "abc");
		System.out.println("洗掉前數量：" + identityService.createUserQuery().userId(id).count());
		// 洗掉用戶
		identityService.deleteUser(id);
		System.out.println("洗掉后數量：" + identityService.createUserQuery().userId(id).count());
	}
	
	//創建用戶方法
	static void creatUser(IdentityService identityService, String id, String first, String last, String email, String passwd) {
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName(first);
		user.setLastName(last);
		user.setEmail(email);
		user.setPassword(passwd);
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
	}

}

驗證用戶密碼
IdentityService中提供了一個checkPassword方法來驗證用戶的密碼，在用戶模塊，需要分清用戶與賬號的概念，對于Activiti來說，用戶是一類資料，而賬號則是從屬于某個用戶的資料，此處所說的驗證密碼，是指驗證用戶的密碼（ACT_ID_USER表的PWD_欄位），而不是用戶賬號的密碼，

package org.crazyit.activiti;

import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.User;

/**
 * 驗證用戶密碼
 * @author yangenxiong
 *
 */
public class CheckPasswd {

	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		String id = UUID.randomUUID().toString();
		// 創建用戶
		creatUser(identityService, id, "angus", "young", "yangenxiong@163.com", "abc");
		// 驗證用戶密碼
		System.out.println("驗證密碼結果：" + identityService.checkPassword(id, "abc"));
		System.out.println("驗證密碼結果：" + identityService.checkPassword(id, "c"));
	}
	
	//創建用戶方法
	static void creatUser(IdentityService identityService, String id, String first, String last, String email, String passwd) {
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName(first);
		user.setLastName(last);
		user.setEmail(email);
		user.setPassword(passwd);
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
	}
}

用戶資料查詢
與用戶組類似，用戶同樣有一個UserQuery查詢物件，并且該物件也提供了相應的查詢與排序方法，我們也可以呼叫list或者singleResult方法回傳查詢資料，UserQuery中包括了如下這些方法，
? userEamil（String email）：根據Email值查詢用戶資料，
? usreEmailLike（String emailLike）：根據Email值模糊查詢用戶資料，
? userFirstName（String firstName）：根據用戶的姓查詢用戶資料，
? userFirstNameLike（String firstNameLike）：根據用戶的姓模糊查詢用戶資料，
? userId（String id）：根據用戶ID查詢用戶資料，
? userLastName（String lastName）：根據用戶的名查詢用戶資料，
? userLastNameLike（String lastNameLike）：根據用戶的名模糊查詢用戶資料，
? memberOfGroup（String groupId）：根據用戶組ID查詢屬于該組的全部用戶資料，
? orderByUserEmail（）：設定根據Email進行排序，
? orderByUserFirstName（）：設定根據用戶的姓進行排序，
? orderByUserId（）：設定根據ID進行排序，
? orderByUserLastName（）：設定根據用戶的名進行排序，
? potentialStarter（String procDefId）：根據流程定義的ID查詢有權限啟動流程定義的用戶，

package org.crazyit.activiti;

import java.util.List;
import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.User;

/**
 * 查詢用戶資料
 * 
 * @author yangenxiong
 *
 */
public class UserQuery {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		String id1 = UUID.randomUUID().toString();
		String id2 = UUID.randomUUID().toString();
		// 創建兩個用戶
		creatUser(identityService, id1, "angus", "young",
				"yangenxiong@163.com", "abc");
		creatUser(identityService, id2, "angus2", "young2", "abc@163.com",
				"123");
		// 呼叫UserQuery的各個查詢方法
		// userId
		User user = identityService.createUserQuery().userId(id1)
				.singleResult();
		System.out.println("userId:" + user.getFirstName());
		// userFirstName
		user = identityService.createUserQuery().userFirstName("angus")
				.singleResult();
		System.out.println("userFirstName:" + user.getFirstName());
		// userFirstNameLike
		List<User> datas = identityService.createUserQuery()
				.userFirstNameLike("angus%").list();
		System.out.println("createUserQuery:" + datas.size());
		// userLastName
		user = identityService.createUserQuery().userLastName("young")
				.singleResult();
		System.out.println("userLastName:" + user.getFirstName());
		// userLastNameLike
		datas = identityService.createUserQuery().userLastNameLike("young%")
				.list();
		System.out.println("userLastNameLike:" + datas.size());
		// userEmail
		user = identityService.createUserQuery().userEmail("abc@163.com")
				.singleResult();
		System.out.println("userEmail:" + user.getFirstName());
		// userEmailLike
		datas = identityService.createUserQuery().userEmailLike("%163.com")
				.list();
		System.out.println("userEmailLike:" + datas.size());
		// 使用NativeQuery
		datas = identityService.createNativeUserQuery()
				.sql("select * from ACT_ID_USER where EMAIL_ = #{email}")
				.parameter("email", "yangenxiong@163.com").list();
		System.out.println("native query:" + datas.get(0).getEmail());
	}

	// 創建用戶方法
	static void creatUser(IdentityService identityService, String id,
			String first, String last, String email, String passwd) {
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName(first);
		user.setLastName(last);
		user.setEmail(email);
		user.setPassword(passwd);
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
	}

}

設定認證用戶
IdentityService中提供了一個setAuthenticatedUserId方法來將用戶ID設定到當前的執行緒中，setAuthenticatedUserId方法最終呼叫的是ThreadLocal的set方法，這意味著，如果啟動兩條執行緒，在執行緒中分別呼叫setAuthenticatedUserId方法，則在相應執行緒中會輸出不同的結果

package org.crazyit.activiti;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.User;
import org.activiti.engine.impl.identity.Authentication;

public class AuthenticatedUserId {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		final IdentityService identityService = engine.getIdentityService();
		// 設定當前執行緒的userId為1
		identityService.setAuthenticatedUserId("3");
		System.out.println("當前執行緒usreId：" + Authentication.getAuthenticatedUserId());
		// 啟動兩條執行緒
		new Thread() {
			public void run() {
				try {
					identityService.setAuthenticatedUserId("1");
					Thread.sleep(5000);
					System.out.println("執行緒1的userId：" + Authentication.getAuthenticatedUserId());
				} catch (Exception e) {
					
				}
			}
		}.start();
		
		new Thread() {
			public void run() {
				identityService.setAuthenticatedUserId("2");
				System.out.println("執行緒2的usrId：" + Authentication.getAuthenticatedUserId());
			}
		}.start();
	}

	//創建用戶方法
	static void creatUser(IdentityService identityService, String id, String first, String last, String email, String passwd) {
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName(first);
		user.setLastName(last);
		user.setEmail(email);
		user.setPassword(passwd);
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
	}
}

用戶資訊管理
在Activiti中，用戶與賬號為不同的概念，用戶資料已經在上一節講述過了，Activiti將一些用戶相關的資訊抽象出來，使用單獨的一個資料表來保存，這些用戶相關的資訊包括賬號資訊和自定義的用戶資訊，這些資訊均保存在ACT_ID_INFO表中，除了這些用戶資訊外，還有用戶的圖片資源，圖片被保存在Activiti公共的資源表ACT_GE_BYTEARRAY中
添加和洗掉用戶資訊
就像用戶組與用戶的資料一樣，同樣有一個物體與用戶資訊映射，對應的物體類為IdentityInfoEntityImpl，但是與用戶和用戶組不一樣的是，Activiti并沒有為其提供相應的Query物件，因為這個表的資料結構是key-value形式，只需要知道key就可以查詢到相應的資料，以下為添加和洗掉用戶方法的描述，
? setUserInfo（String userId，String key，String value）：為用戶添加用戶資訊，第一個引數為用戶資料的ID，第二個引數為用戶資訊的名稱，第三個引數為該用戶資訊的值，
? deleteUserInfo（String userId，String key）：洗掉用戶資訊，第一個引數為用戶ID，第二個引數為用戶資訊的名稱，

package org.crazyit.activiti;

import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.User;

/**
 * 添加洗掉用戶資訊
 * @author yangenxiong
 *
 */
public class AddDeleteUserInfo {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		String id = UUID.randomUUID().toString();
		// 創建用戶
		creatUser(identityService, id, "angus", "young", "yangenxiong@163.com", "abc");
		// 創建一個用戶資訊
		identityService.setUserInfo(id, "age", "30");
		// 創建第二個用戶資訊
		identityService.setUserInfo(id, "weight", "60KG");
		// 洗掉用戶年齡資訊
		identityService.deleteUserInfo(id, "age");
	}

	//創建用戶方法
	static void creatUser(IdentityService identityService, String id, String first, String last, String email, String passwd) {
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName(first);
		user.setLastName(last);
		user.setEmail(email);
		user.setPassword(passwd);
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
	}
}

查詢用戶資訊
成功將用戶資訊保存到資料庫后，如果需要使用這些資訊，則可以呼叫IdentityService的getUserInfo方法來查找這些資訊，使用該方法需要提供用戶的ID與資訊的鍵值，呼叫該方法后，將回傳相應資訊的字串，

package org.crazyit.activiti;

import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.User;

/**
 * 查詢用戶資訊
 * @author yangenxiong
 *
 */
public class GetUserInfo {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		String id = UUID.randomUUID().toString();
		// 創建用戶
		creatUser(identityService, id, "angus", "young", "yangenxiong@163.com", "abc");
		// 創建一個用戶資訊
		identityService.setUserInfo(id, "age", "30");
		// 創建第二個用戶資訊
		identityService.setUserInfo(id, "weight", "60KG");
		// 查詢用戶資訊
		String value = identityService.getUserInfo(id, "age");
		System.out.println("用戶年齡為：" + value);
	}

	//創建用戶方法
	static void creatUser(IdentityService identityService, String id, String first, String last, String email, String passwd) {
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName(first);
		user.setLastName(last);
		user.setEmail(email);
		user.setPassword(passwd);
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
	}
}

設定用戶圖片
Activiti專門提供了一個資料表來保存檔案資料，即ACT_GE_BYTEARRAY表，Activiti會讀取檔案，并將這些檔案轉換為byte陣列，然后保存到表中，IdentityService提供了setUserPicture和getUserPicture方法用來設定和查找用戶圖片資料，其中對setUserPicture方法需要設定兩個引數：用戶ID和Picture實體，

package org.crazyit.activiti;

import java.awt.image.BufferedImage;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.util.UUID;

import javax.imageio.ImageIO;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Picture;
import org.activiti.engine.identity.User;

/**
 * 設定用戶圖片
 * @author yangenxiong
 *
 */
public class UserPicture {

	public static void main(String[] args) throws Exception {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		String id = UUID.randomUUID().toString();
		// 創建用戶
		creatUser(identityService, id, "angus", "young", "yangenxiong@163.com", "abc");
		// 讀取圖片并轉換為byte陣列
		FileInputStream fis = new FileInputStream(new File("resource/artifact/picture.png"));		
		BufferedImage img = ImageIO.read(fis);
		ByteArrayOutputStream output = new ByteArrayOutputStream();
		ImageIO.write(img, "png", output);
		//獲取圖片的byte陣列
		byte[] picArray = output.toByteArray();		
		// 創建Picture實體
		Picture picture = new Picture(picArray, "angus image");
		// 為用戶設定圖片
		identityService.setUserPicture(id, picture);		
	}

	//創建用戶方法
	static void creatUser(IdentityService identityService, String id, String first, String last, String email, String passwd) {
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName(first);
		user.setLastName(last);
		user.setEmail(email);
		user.setPassword(passwd);
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
	}
}

用戶組與用戶的關系
在Activiti中，一個用戶可以被分配到多個用戶組中，一個用戶組中可以包含多個用戶，針對這種情況，Activiti使用了中間表來保存這兩種資料間的關系，通過關系表的資料，可以清楚地看到用戶組與用戶之間的關系，Activiti也提供了相應的API來操作這種關系，這個中間表為ACT_ID_MEMBERSHIP表，這里需要注意的是，Activiti并沒有為這個表做物體的映射，
系結關系
系結關系，意味著向ACT_ID_MEMBERSHIP表寫入一條關系資料，只需要指定這個關系的用戶ID和用戶組ID，再呼叫IdentityService的createMembership方法即可，該方法第一個引數為用戶ID，第二個引數為用戶組ID，

package org.crazyit.activiti;

import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;
import org.activiti.engine.identity.User;

/**
 * 系結用戶組與用戶的關系
 * 
 * @author yangenxiong
 *
 */
public class CreateMemberShip {

	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 保存一個用戶
		User user = creatUser(identityService, UUID.randomUUID().toString(),
				"angus", "young", "yangenxiong@163.com", "abc");
		// 保存一個用戶組
		Group group = createGroup(identityService,
				UUID.randomUUID().toString(), "經理組", "manager");
		// 系結關系
		identityService.createMembership(user.getId(), group.getId());
	}

	// 創建用戶方法
	static User creatUser(IdentityService identityService, String id,
			String first, String last, String email, String passwd) {
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName(first);
		user.setLastName(last);
		user.setEmail(email);
		user.setPassword(passwd);
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
		return identityService.createUserQuery().userId(id).singleResult();
	}

	// 將用戶組資料保存到資料庫中
	static Group createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
		return identityService.createGroupQuery().groupId(id).singleResult();
	}
}

解除系結

package org.crazyit.activiti;

import java.util.List;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;
import org.activiti.engine.identity.User;

/**
 * 根據用戶組ID查詢用戶組下的用戶
 * @author yangenxiong
 *
 */
public class DeleteMemberShip {

	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 保存兩個用戶
		User user = creatUser(identityService, "1", "angus", "young", "yangenxiong@163.com", "abc");
		// 保存一個用戶組
		Group group = createGroup(identityService, "2", "Group A", "manager");
		// 將兩個用戶分配到用戶組下
		identityService.createMembership(user.getId(), group.getId());
		// 洗掉系結關系
		identityService.deleteMembership(user.getId(), group.getId());
	}

	//創建用戶方法
	static User creatUser(IdentityService identityService, String id, String first, String last, String email, String passwd) {
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName(first);
		user.setLastName(last);
		user.setEmail(email);
		user.setPassword(passwd);
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
		return identityService.createUserQuery().userId(id).singleResult();
	}
	
	// 將用戶組資料保存到資料庫中
	static Group createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
		return identityService.createGroupQuery().groupId(id).singleResult();
	}
}

查詢用戶組下的用戶
根據中間表的設計，大致可以猜到memberOfGroup方法的實作程序，先到ACT_ID_MEMBERSHIP表中根據groupId進行查詢，獲取全部的userId后，再到ACT_ID_USER表中查詢用戶資料

package org.crazyit.activiti;

import java.util.List;
import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;
import org.activiti.engine.identity.User;

/**
 * 系結用戶組與用戶的關系
 * 
 * @author yangenxiong
 *
 */
public class QueryUsersByGroup {

	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 保存兩個用戶
		User user1 = creatUser(identityService, UUID.randomUUID().toString(),
				"張經理", "young", "yangenxiong@163.com", "abc");
		User user2 = creatUser(identityService, UUID.randomUUID().toString(),
				"李經理", "young2", "yangenxiong@163.com", "abc");
		// 保存一個用戶組
		Group group = createGroup(identityService,
				UUID.randomUUID().toString(), "經理組", "manager");
		// 將兩個用戶分配到用戶組下
		identityService.createMembership(user1.getId(), group.getId());
		identityService.createMembership(user2.getId(), group.getId());
		List<User> users = identityService.createUserQuery()
				.memberOfGroup(group.getId()).list();
		System.out.println("經理組有如下人員：");
		for (User user : users) {
			System.out.println(user.getFirstName());
		}
	}

	// 創建用戶方法
	static User creatUser(IdentityService identityService, String id,
			String first, String last, String email, String passwd) {
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName(first);
		user.setLastName(last);
		user.setEmail(email);
		user.setPassword(passwd);
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
		return identityService.createUserQuery().userId(id).singleResult();
	}

	// 將用戶組資料保存到資料庫中
	static Group createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
		return identityService.createGroupQuery().groupId(id).singleResult();
	}
}

查詢用戶所屬的用戶組
與memberOfGroup方法類似，groupMember方法會根據用戶的ID，查詢該用戶所屬的用戶組，同樣，該方法會到中間表中查詢該用戶的全部關系資料并且得到groupId，然后根據這些groupId再到用戶組的表中查詢用戶組資料，

package org.crazyit.activiti;

import java.util.List;
import java.util.UUID;

import org.activiti.engine.IdentityService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.identity.Group;
import org.activiti.engine.identity.User;

/**
 * 系結用戶組與用戶的關系
 * 
 * @author yangenxiong
 *
 */
public class QueryGroupsByUser {

	public static void main(String[] args) {
		// 創建流程引擎
		ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
		// 得到身份服務組件實體
		IdentityService identityService = engine.getIdentityService();
		// 創建一個用戶
		User user = creatUser(identityService, UUID.randomUUID().toString(),
				"張三", "young", "yangenxiong@163.com", "abc");
		// 創建兩個用戶組
		Group group1 = createGroup(identityService, UUID.randomUUID()
				.toString(), "經理組", "manager");
		Group group2 = createGroup(identityService, UUID.randomUUID()
				.toString(), "員工組", "manager");
		// 將用戶與兩個用戶組系結關系
		identityService.createMembership(user.getId(), group1.getId());
		identityService.createMembership(user.getId(), group2.getId());
		// 呼叫memberOfGroup方法查詢用戶所在的用戶組
		List<Group> groups = identityService.createGroupQuery()
				.groupMember(user.getId()).list();
		System.out.println("張三屬于的用戶組有：");
		for (Group group : groups) {
			System.out.println(group.getName());
		}
	}

	// 創建用戶方法
	static User creatUser(IdentityService identityService, String id,
			String first, String last, String email, String passwd) {
		// 使用newUser方法創建User實體
		User user = identityService.newUser(id);
		// 設定用戶的各個屬性
		user.setFirstName(first);
		user.setLastName(last);
		user.setEmail(email);
		user.setPassword(passwd);
		// 使用saveUser方法保存用戶
		identityService.saveUser(user);
		return identityService.createUserQuery().userId(id).singleResult();
	}

	// 將用戶組資料保存到資料庫中
	static Group createGroup(IdentityService identityService, String id,
			String name, String type) {
		// 呼叫newGroup方法創建Group實體
		Group group = identityService.newGroup(id);
		group.setName(name);
		group.setType(type);
		identityService.saveGroup(group);
		return identityService.createGroupQuery().groupId(id).singleResult();
	}
}

轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/243909.html

標籤：其他

上一篇：05.Hibernate中的關聯關系映射,物件查詢,二級快取

下一篇：MySql之表的創建、插入與洗掉

標籤雲
其他(157675) Python(38076) JavaScript(25376) Java(17977) C(15215) 區塊鏈(8255) C＃(7972) AI(7469) 爪哇(7425) MySQL(7132) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5869) 数组(5741) R(5409) Linux(5327) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4554) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2429) ASP.NET(2402) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) 功能(1967) .NET技术(1958) Web開發(1951) python-3.x(1918) HtmlCss(1915) 弹簧靴(1913) C++(1909) xml(1889) PostgreSQL(1872) .NETCore(1853) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽
  • GPU虛擬機創建時間深度優化

    **?桔妹導讀：**GPU虛擬機實體創建速度慢是公有云面臨的普遍問題，由于通常情況下創建虛擬機屬于低頻操作而未引起業界的重視，實際生產中還是存在對GPU實體創建時間有苛刻要求的業務場景。本文將介紹滴滴云在解決該問題時的思路、方法、并展示最終的優化成果。 從公有云服務商那里購買過虛擬主機的資深用戶，一 ......

    uj5u.com 2020-09-10 06:09:13 more
  • 可編程網卡芯片在滴滴云網路的應用實踐

    **?桔妹導讀：**隨著云規模不斷擴大以及業務層面對延遲、帶寬的要求越來越高，采用DPDK 加速網路報文處理的方式在橫向縱向擴展都出現了局限性。可編程芯片成為業界熱點。本文主要講述了可編程網卡芯片在滴滴云網路中的應用實踐，遇到的問題、帶來的收益以及開源社區貢獻。 #1. 資料中心面臨的問題 隨著滴滴 ......

    uj5u.com 2020-09-10 06:10:21 more
  • 滴滴資料通道服務演進之路

    **?桔妹導讀：**滴滴資料通道引擎承載著全公司的資料同步，為下游實時和離線場景提供了必不可少的源資料。隨著任務量的不斷增加，資料通道的整體架構也隨之發生改變。本文介紹了滴滴資料通道的發展歷程，遇到的問題以及今后的規劃。 #1. 背景 資料，對于任何一家互聯網公司來說都是非常重要的資產，公司的大資料 ......

    uj5u.com 2020-09-10 06:11:05 more
  • 滴滴AI Labs斬獲國際機器翻譯大賽中譯英方向世界第三

    **桔妹導讀：**深耕人工智能領域，致力于探索AI讓出行更美好的滴滴AI Labs再次斬獲國際大獎，這次獲獎的專案是什么呢？一起來看看詳細報道吧！ 近日，由國際計算語言學協會ACL（The Association for Computational Linguistics）舉辦的世界最具影響力的機器 ......

    uj5u.com 2020-09-10 06:11:29 more
  • MPP (Massively Parallel Processing)大規模并行處理

    1、什么是mpp？ MPP (Massively Parallel Processing)，即大規模并行處理，在資料庫非共享集群中，每個節點都有獨立的磁盤存盤系統和記憶體系統，業務資料根據資料庫模型和應用特點劃分到各個節點上，每臺資料節點通過專用網路或者商業通用網路互相連接，彼此協同計算，作為整體提供 ......

    uj5u.com 2020-09-10 06:11:41 more
  • 滴滴資料倉庫指標體系建設實踐

    **桔妹導讀：**指標體系是什么？如何使用OSM模型和AARRR模型搭建指標體系？如何統一流程、規范化、工具化管理指標體系？本文會對建設的方法論結合滴滴資料指標體系建設實踐進行解答分析。 #1. 什么是指標體系 ##1.1 指標體系定義 指標體系是將零散單點的具有相互聯系的指標，系統化的組織起來，通 ......

    uj5u.com 2020-09-10 06:12:52 more
  • 單表千萬行資料庫 LIKE 搜索優化手記

    我們經常在資料庫中使用 LIKE 運算子來完成對資料的模糊搜索，LIKE 運算子用于在 WHERE 子句中搜索列中的指定模式。 如果需要查找客戶表中所有姓氏是“張”的資料，可以使用下面的 SQL 陳述句： SELECT * FROM Customer WHERE Name LIKE '張%' 如果需要 ......

    uj5u.com 2020-09-10 06:13:25 more
  • 滴滴Ceph分布式存盤系統優化之鎖優化

    **桔妹導讀：**Ceph是國際知名的開源分布式存盤系統，在工業界和學術界都有著重要的影響。Ceph的架構和演算法設計發表在國際系統領域頂級會議OSDI、SOSP、SC等上。Ceph社區得到Red Hat、SUSE、Intel等大公司的大力支持。Ceph是國際云計算領域應用最廣泛的開源分布式存盤系統， ......

    uj5u.com 2020-09-10 06:14:51 more
  • es~通過ElasticsearchTemplate進行聚合~嵌套聚合

    之前寫過《es~通過ElasticsearchTemplate進行聚合操作》的文章，這一次主要寫一個嵌套的聚合，例如先對sex集合，再對desc聚合，最后再對age求和，共三層嵌套。 Aggregations的部分特性類似于SQL語言中的group by，avg，sum等函式,Aggregation ......

    uj5u.com 2020-09-10 06:14:59 more
  • 爬蟲日志監控 -- Elastc Stack（ELK）部署

    傻瓜式部署，只需替換IP與用戶 導讀： 現ELK四大組件分別為：Elasticsearch（核心）、logstash（處理）、filebeat（采集）、kibana（可視化） 下載均在https://www.elastic.co/cn/downloads/下tar包，各組件版本最好一致，配合fdm會 ......

    uj5u.com 2020-09-10 06:15:05 more
最新发布
  • day02-2-商鋪查詢快取

    功能02-商鋪查詢快取 3.商鋪詳情快取查詢 3.1什么是快取？ 快取就是資料交換的緩沖區（稱作Cache），是存盤資料的臨時地方，一般讀寫性能較高。 快取的作用： 降低后端負載 提高讀寫效率，降低回應時間 快取的成本： 資料一致性成本 代碼維護成本 運維成本 3.2需求說明 如下，當我們點擊商店詳 ......

    uj5u.com 2023-04-20 08:33:24 more
  • MySQL中binlog備份腳本分享

    關于MySQL的二進制日志（binlog），我們都知道二進制日志（binlog）非常重要，尤其當你需要point to point災難恢復的時侯，所以我們要對其進行備份。關于二進制日志（binlog)的備份,可以基于flush logs方式先切換binlog，然后拷貝&壓縮到到遠程服務器或本地服務器 ......

    uj5u.com 2023-04-20 08:28:06 more
  • day02-短信登錄

    功能實作02 2.功能01-短信登錄 2.1基于Session實作登錄 2.1.1思路分析 2.1.2代碼實作 2.1.2.1發送短信驗證碼 發送短信驗證碼： 發送驗證碼的介面為：http://127.0.0.1:8080/api/user/code?phone=xxxxx<手機號> 請求方式：PO ......

    uj5u.com 2023-04-20 08:27:27 more
  • 快取與資料庫雙寫一致性幾種策略分析

    本文將對幾種快取與資料庫保證資料一致性的使用方式進行分析。為保證高并發性能，以下分析場景不考慮執行的原子性及加鎖等強一致性要求的場景，僅追求最終一致性。 ......

    uj5u.com 2023-04-20 08:26:48 more
  • sql陳述句優化

    問題查找及措施 問題查找 需要找到具體的代碼，對其進行一對一優化，而非一直把關注點放在服務器和sql平臺 降低簡化每個事務中處理的問題，盡量不要讓一個事務拖太長的時間 例如檔案上傳時，應將檔案上傳這一步放在事務外面 微軟建議 4.啟動sql定時執行計劃 怎么啟動sqlserver代理服務-百度經驗 ......

    uj5u.com 2023-04-20 08:26:35 more
  • 云時代，MySQL到ClickHouse資料同步產品對比推薦

    ClickHouse 在執行分析查詢時的速度優勢很好的彌補了MySQL的不足，但是對于很多開發者和DBA來說，如何將MySQL穩定、高效、簡單的同步到 ClickHouse 卻很困難。本文對比了 NineData、MaterializeMySQL（ClickHouse自帶）、Bifrost 三款產品... ......

    uj5u.com 2023-04-20 08:26:29 more
  • sql陳述句優化

    問題查找及措施 問題查找 需要找到具體的代碼，對其進行一對一優化，而非一直把關注點放在服務器和sql平臺 降低簡化每個事務中處理的問題，盡量不要讓一個事務拖太長的時間 例如檔案上傳時，應將檔案上傳這一步放在事務外面 微軟建議 4.啟動sql定時執行計劃 怎么啟動sqlserver代理服務-百度經驗 ......

    uj5u.com 2023-04-20 08:25:13 more
  • Redis 報”OutOfDirectMemoryError“（堆外記憶體溢位)

    Redis 報錯“OutOfDirectMemoryError（堆外記憶體溢位) ”問題如下： 一、報錯資訊： 使用 Redis 的業務介面 ，產生 OutOfDirectMemoryError（堆外記憶體溢位），如圖： 格式化后的報錯資訊： { "timestamp": "2023-04-17 22: ......

    uj5u.com 2023-04-20 08:24:54 more
  • day02-2-商鋪查詢快取

    功能02-商鋪查詢快取 3.商鋪詳情快取查詢 3.1什么是快取？ 快取就是資料交換的緩沖區（稱作Cache），是存盤資料的臨時地方，一般讀寫性能較高。 快取的作用： 降低后端負載 提高讀寫效率，降低回應時間 快取的成本： 資料一致性成本 代碼維護成本 運維成本 3.2需求說明 如下，當我們點擊商店詳 ......

    uj5u.com 2023-04-20 08:24:03 more
  • day02-短信登錄

    功能實作02 2.功能01-短信登錄 2.1基于Session實作登錄 2.1.1思路分析 2.1.2代碼實作 2.1.2.1發送短信驗證碼 發送短信驗證碼： 發送驗證碼的介面為：http://127.0.0.1:8080/api/user/code?phone=xxxxx<手機號> 請求方式：PO ......

    uj5u.com 2023-04-20 08:23:11 more

Copyright © 2010-2020 有解無憂