后台数据库的访问必须使用后台接口实现的方法,并且配置文件,见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()); |
|