0

src/main/java/com/ekexiu/console/system/dao/UserRoleDao.java

import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.orm.annotation.dao.Batch;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.operator.Delete;
import org.jfw.apt.orm.annotation.dao.method.operator.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import com.ekexiu.console.system.po.UserRole;
	@From(UserRole.class)
	int deleteByRoleId(Connection con,String roleid)throws SQLException;
	
	@SelectList
	List<UserRole> queryByUserId(Connection con, String userid) throws SQLException;
	
}

src/main/java/com/ekexiu/console/system/po/Role.java

public class Role implements CreateTimeSupported,ModifyTimeSupported,DescpSupported{
	private String id;
	private String name;
	private String type;
	private String authinfo;
	private String descp;
	private String createTime;
	public void setName(String name) {
		this.name = name;
	}
	@Column(DE.singleChar)
	public String getType() {
		return type;
	}
	public void setType(String type) {
		this.type = type;
	}
	@Column(DE.string_de)
	public String getAuthinfo() {
		return authinfo;

src/main/java/com/ekexiu/console/system/service/RoleService.java

		r.setId(id);
		r.setName(role.getName());
		r.setDescp(role.getDescp());
		r.setType(role.getType());
		int[] auths = role.getAuths();
		if (auths == null || auths.length == 0) {
			r.setAuthinfo(EMPTY_AUTH_STR);
	public void update(@JdbcConn final Connection con, @RequestBody final ConsoleAuthRole role) throws SQLException {
		final AtomicBoolean ab = new AtomicBoolean(false);
		JdbcUtil.executeAutoCommit(con, new JdbcTask() {
			@Override
			public void exec() throws SQLException {
				Role r = new Role();
				r.setId(role.getId());
				r.setType(role.getType());
				r.setName(role.getName());
				r.setDescp(role.getDescp());
				int[] auths = role.getAuths();
		ConsoleAuthRole cr = new ConsoleAuthRole();
		cr.setDescp(role.getDescp());
		cr.setId(role.getId());
		cr.setType(role.getType());
		cr.setName(role.getName());
		cr.setAuths(AuthUtil.unCompress(AuthUtil.deSerialAuth(role.getAuthinfo())));
		return cr;

src/main/java/com/ekexiu/console/system/service/UserRoleService.java

import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.PathVar;
import com.ekexiu.console.system.dao.UserRoleDao;
import com.ekexiu.console.system.po.UserRole;
	public void setUserRoleDao(UserRoleDao userRoleDao) {
		this.userRoleDao = userRoleDao;
	}
	public void insert(@JdbcConn(true) Connection con,String userid,String[] role)throws SQLException{
    @Post
    @Path()
	public void save(@JdbcConn(true) Connection con,String userid,String[] role)throws SQLException{
		this.userRoleDao.deleteByUserId(con, userid);
		UserRole[] urs = new UserRole[role.length];
		int ind = 0;
		this.userRoleDao.insert(con, urs);
	}
	
	@Get
	@Path("/user/{id}")
	public List<UserRole> getRole(@JdbcConn Connection con,@PathVar String id)throws SQLException{
		return this.userRoleDao.queryByUserId(con,id);
	}
}

src/main/java/com/ekexiu/console/system/vo/ConsoleAuthRole.java

public class ConsoleAuthRole {
	private String id;
	private String name;
	private String type;
	private int[] auths;
	private String descp;
	public String getId() {
	public void setName(String name) {
		this.name = name;
	}
	
	public String getType() {
		return type;
	}
	public void setType(String type) {
		this.type = type;
	}
	public int[] getAuths() {
		return auths;
	}

src/test/java/com/ekexiu/console/util/JdbcTest.java

package com.ekexiu.console.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class JdbcTest {
public static void main(String[] args)throws Exception{
	//Class.forName(className)
	
	Connection con = DriverManager.getConnection("jdbc:postgresql://192.168.3.233:5432/console_dev_jp", "postgres","postgres");
	
	PreparedStatement ps = con.prepareStatement("INSERT INTO TEST (ID,NAME,CODE) SELECT ?,NAME,CODE FROM  TEST WHERE ID=?");
	ps.setString(1,"4");
	ps.setString(2,"1");
	System.out.println(ps.executeUpdate());
	ps.close();
	con.close();
}
}