该楼层疑似违规已被系统折叠 隐藏此楼查看此楼

直接项目里找了一段代码，自己看吧

public BasicUser getUser(IUser user) throws Exception {

String sql = "select id,nickName,jifen,jingyan,qdTime,lxqdDay,"

+ "extendApp from basic where id=?";

PreparedStatement pstmt = connection.prepareStatement(sql);

pstmt.setString(1, user.getId());

ResultSet res = pstmt.executeQuery();

if (!res.next()) {

return null;

}

BasicUser queryUser = new BasicUser();

queryUser.setId(res.getString(1));

queryUser.setNickName(res.getString(2));

queryUser.setJifen(res.getInt(3));

queryUser.setJingyan(res.getInt(4));

queryUser.setQdTime(res.getLong(5));

queryUser.setLxqdDays(res.getInt(6));

queryUser.setExtendApp(getExtendApps(res.getBlob(7)));

pstmt.close();

return queryUser;

}

@SuppressWarnings("unchecked")

private List getExtendApps(Blob b) throws Exception {

if (b == null) {

return null;

}

ObjectInputStream in = new ObjectInputStream(b.getBinaryStream());

List extendApps = (List) in.readObject();

return extendApps;

}

public void setUser(BasicUser user) throws Exception {

String sql = "update basic set nickName=?,jifen=?,jingyan=?,qdTime=?,"

+ "lxqdDay=?,extendApp=? where id=?";

PreparedStatement pstmt = connection.prepareStatement(sql);

pstmt.setString(1, user.getNickName());

pstmt.setInt(2, user.getJifen());

pstmt.setInt(3, user.getJingyan());

pstmt.setLong(4, user.getQdTime());

pstmt.setInt(5, user.getLxqdDays());

pstmt.setBlob(6, getExtendAppStream(user.getExtendApp()));

pstmt.setString(7, user.getId());

pstmt.execute();

pstmt.close();

}

private InputStream getExtendAppStream(List extendApp)

throws Exception {

if (extendApp == null) {

return null;

}

ByteArrayOutputStream buffer = new ByteArrayOutputStream();

ObjectOutputStream out = new ObjectOutputStream(buffer);

out.writeObject(extendApp);

InputStream in = new ByteArrayInputStream(buffer.toByteArray());

return in;

}