- package com.dao;
- import com.tool.SQLCode;
- import java.util.List;
- import com.domain.CqyzxForm;
- import com.tool.JDBConnection;
- import java.util.ArrayList;
- import java.sql.ResultSet;
- import java.sql.*;
- //修改的操作
- public class CqyzxDaoImpl
- implements CqyzxDao {
- public List qyzxSelect() {
- JDBConnection connection = new JDBConnection();
- List list = new ArrayList();
- String sql = SQLCode.getSQLCode("sql.qyzx.select");
- CqyzxForm form = null;
- try {
- ResultSet rs = connection.executeQuery(sql);
- while (rs.next()) {
- form = new CqyzxForm();
- form.setQyzx_id(rs.getString(1));
- form.setQyzx_zxjb(rs.getString(2));
- form.setQyzx_bz(rs.getString(3));
- list.add(form);
- }
- }
- catch (SQLException ex) {
- }
- connection.close();
- return list;
- }
- //删除的操作
- public void qyzxDelete(CqyzxForm qyzx) {
- JDBConnection connection = new JDBConnection();
- String sql = SQLCode.getSQLCode("sql.qyzx.delete");
- sql = connection.editSqlCode(sql, qyzx.getQyzx_id());
- connection.executeUpdate(sql);
- connection.close();
- }
- //单独查询
- public CqyzxForm qyzxSelectOne(CqyzxForm qyzx) {
- JDBConnection connection = new JDBConnection();
- CqyzxForm form = null;
- String sql = SQLCode.getSQLCode("sql.qyzx.selectOne");
- sql = connection.editSqlCode(sql, qyzx.getQyzx_id());
- try {
- ResultSet rs = connection.executeQuery(sql);
- while (rs.next()) {
- form = new CqyzxForm();
- form.setQyzx_id(rs.getString(1));
- form.setQyzx_zxjb(rs.getString(2));
- form.setQyzx_bz(rs.getString(3));
- }
- }
- catch (SQLException ex) {
- }
- return form;
- }
- //修改操作
- public void qyzxUpdate(CqyzxForm qyzx) {
- JDBConnection connection = new JDBConnection();
- String sql = SQLCode.getSQLCode("sql.qyzx.update");
- sql = connection.editSqlCode(sql, qyzx.getQyzx_zxjb());
- sql = connection.editSqlCode(sql, qyzx.getQyzx_bz());
- sql = connection.editSqlCode(sql, qyzx.getQyzx_id());
- connection.executeUpdate(sql);
- connection.close();
- }
- //以数据库中的记录数,查找出多少记录计算,以便做帐号存贮--
- public int qyzxCount() {
- int iCount = 0;
- JDBConnection connection = new JDBConnection();
- String sql = SQLCode.getSQLCode("sql.qyzx.count");
- ResultSet rs = null;
- try {
- rs = connection.executeQuery(sql);
- while (rs.next()) {
- CqyzxForm form = new CqyzxForm();
- iCount = rs.getInt("t");
- }
- }
- catch (SQLException ex) {
- }
- connection.close();
- return iCount + 1;
- }
- //插入操作
- public void qyzxInsert(CqyzxForm qyzx) {
- JDBConnection connection = new JDBConnection();
- String sql = SQLCode.getSQLCode("sql.qyzx.insert");
- sql = connection.editSqlCode(sql, qyzx.getQyzx_id());
- sql = connection.editSqlCode(sql, qyzx.getQyzx_zxjb());
- sql = connection.editSqlCode(sql, qyzx.getQyzx_bz());
- connection.executeUpdate(sql);
- connection.close();
- }
- }