|
马上注册,结交更多好友,享用更多功能,让你轻松玩转社区。
您需要 登录 才可以下载或查看,没有账号?注册账号
×
后台数据库的访问必须使用后台接口实现的方法,并且配置文件,见NC502后台接口的使用
一 BaseDAO
new BaseDAO(). insertObject()
二 PersistenceManager
A.JdbcSession的创建
PersistenceManager sessionManager= PersistenceManager. getInstance ();
try {
JdbcSession session = sessionManager. getJdbcSession ();
//数据库访问操作
session.insert(…);
session.update(…);
session.query(…);
} catch (DbException e) {
}
finally {
sessionManager. release ();//需要关闭会话
}
B.JdbcSession基本操作
1.无参查询
String sql = "select * from bd_deptdoc"; //构造查询语句
List list = (List) session.executeQuery(sql, new ArrayListProcessor());
2.有参查询
String sql = "select * from bd_deptdoc where dept_code=?";
SQLParameter param = new SQLParameter(); //构造参数对象
param.addParam(“aaa”); //添加参数
List list=(List) session.executeQuery(sql, param, new ArrayListProcessor());
3.无参更新
String sql = "update bd_deptdoc set dept_code =‘aaa’
where dept_code=‘bbb’";
session.executeUpdate(sql);
4.有参更新
String sql = "update bd_deptdoc set dept_code =‘aaa’
where dept_code=?”;
SQLParameter param = new SQLParameter(); //构造参数对象
param.addParam(“bbb”); //添加参数
session.executeUpdate(sql, param);
5.无参批量更新
String sql = "update bd_deptdoc set dept_code =‘aaa’ where dept_code=‘bbb’";
session.addBatch(sql); //添加需要执行的同构SQL
int rows = session.executeBatch(); //执行
6.有参批量更新
String sql = "update bd_deptdoc set dept_code =‘aaa’ where dept_code=?”;
SQLParameter param = new SQLParameter(); //构造参数对象
param.addParam(“bbb”); //添加参数
session.addBatch(sql, param); //添加需要执行的同构SQL
int rows = session.executeBatch(); //执行
C.特殊参数
1. Null参数
param.addNullParam(java.sql.Types.INTEGER);
2. Blob参数
param.addBlobParam (new Object());
3. Clob参数
param.addClobParam (new String()); |
|