BaseDao.java
上传用户:njlgjx
上传日期:2022-08-07
资源大小:9105k
文件大小:4k
源码类别:

图形图象

开发平台:

Java

  1. /*
  2.  * To change this template, choose Tools | Templates
  3.  * and open the template in the editor.
  4.  */
  5. package com.mwq.map.dao;
  6. import java.sql.Connection;
  7. import java.sql.ResultSet;
  8. import java.sql.SQLException;
  9. import java.sql.Statement;
  10. import java.util.Vector;
  11. /**
  12.  *
  13.  * @author Administrator
  14.  */
  15. public class BaseDao {
  16.     // 查询多个记录
  17.     public Vector<Vector> selectSomeNote(String sql) {
  18.         Vector<Vector> rsV = new Vector<Vector>();// 创建结果集向量
  19.         Connection conn = JDBC.getConnection();// 获得数据库连接
  20.         try {
  21.             Statement stmt = conn.createStatement();// 创建连接状态对象
  22.             ResultSet rs = stmt.executeQuery(sql);// 执行SQL语句获得查询结果
  23.             int columnCount = rs.getMetaData().getColumnCount();// 获得查询数据表的列数
  24.             while (rs.next()) {// 遍历结果集
  25.                 Vector<Object> rowV = new Vector<Object>();// 创建行向量
  26.                 for (int column = 1; column <= columnCount; column++) {
  27.                     rowV.add(rs.getObject(column));// 添加列值
  28.                 }
  29.                 rsV.add(rowV);// 将行向量添加到结果集向量中
  30.             }
  31.             rs.close();// 关闭结果集对象
  32.             stmt.close();// 关闭连接状态对象
  33.         } catch (SQLException e) {
  34.             e.printStackTrace();
  35.         }
  36.         return rsV;// 返回结果集向量
  37.     }
  38.     // 查询单个记录
  39.     public Vector selectOnlyNote(String sql) {
  40.         Vector<Object> rowV = null;
  41.         Connection conn = JDBC.getConnection();
  42.         try {
  43.             Statement stmt = conn.createStatement();
  44.             ResultSet rs = stmt.executeQuery(sql);
  45.             int columnCount = rs.getMetaData().getColumnCount();
  46.             while (rs.next()) {
  47.                 rowV = new Vector<Object>();
  48.                 for (int column = 1; column <= columnCount; column++) {
  49.                     rowV.add(rs.getObject(column));
  50.                 }
  51.             }
  52.             rs.close();
  53.             stmt.close();
  54.         } catch (SQLException e) {
  55.             e.printStackTrace();
  56.         }
  57.         return rowV;
  58.     }
  59.     // 查询多个值
  60.     public Vector selectSomeValue(String sql) {
  61.         Vector<Object> valueV = new Vector<Object>();
  62.         Connection conn = JDBC.getConnection();
  63.         try {
  64.             Statement stmt = conn.createStatement();
  65.             ResultSet rs = stmt.executeQuery(sql);
  66.             while (rs.next()) {
  67.                 valueV.add(rs.getObject(1));
  68.             }
  69.             rs.close();
  70.             stmt.close();
  71.         } catch (SQLException e) {
  72.             e.printStackTrace();
  73.         }
  74.         return valueV;
  75.     }
  76.     // 查询单个值
  77.     public Object selectOnlyValue(String sql) {
  78.         Object value = null;
  79.         Connection conn = JDBC.getConnection();
  80.         try {
  81.             Statement stmt = conn.createStatement();
  82.             ResultSet rs = stmt.executeQuery(sql);
  83.             while (rs.next()) {
  84.                 value = rs.getObject(1);
  85.             }
  86.             rs.close();
  87.             stmt.close();
  88.         } catch (SQLException e) {
  89.             e.printStackTrace();
  90.         }
  91.         return value;
  92.     }
  93.     // 插入、修改、删除记录
  94.     public boolean longHaul(String sql) {
  95.         boolean isLongHaul = true;// 默认持久化成功
  96.         Connection conn = JDBC.getConnection();// 获得数据库连接
  97.         try {
  98.             conn.setAutoCommit(false);// 设置为手动提交
  99.             Statement stmt = conn.createStatement();// 创建连接状态对象
  100.             stmt.executeUpdate(sql);// 执行SQL语句
  101.             stmt.close();// 关闭连接状态对象
  102.             conn.commit();// 提交持久化
  103.         } catch (SQLException e) {
  104.             isLongHaul = false;// 持久化失败
  105.             try {
  106.                 conn.rollback();// 回滚
  107.             } catch (SQLException e1) {
  108.                 e1.printStackTrace();
  109.             }
  110.             e.printStackTrace();
  111.         }
  112.         return isLongHaul;// 返回持久化结果
  113.     }
  114. }