当前位置:编程学习 > JAVA >>

java(JDBC连接数据库)[对Statement进行封装]

[java] 
package com.iflytec.ex02; 
 
import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.ResultSet; 
import java.sql.ResultSetMetaData; 
import java.sql.SQLException; 
import java.sql.Statement; 
import java.util.ArrayList; 
import java.util.HashMap; 
import java.util.List; 
import java.util.Map; 
 
/**
 * 数据连接类
 * 
 * @author iflytek
 * @version 1.0
 */ 
public class ConnectionDB { 
    /**
     * 数据库驱动类名称
     */ 
    private static final String DRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; 
 
    /**
     * 连接字符串
     */ 
    private static final String URLSTR = "jdbc:sqlserver://localhost:1433; databaseName=Northwind"; 
 
    /**
     * 用户名
     */ 
    private static final String USERNAME = "sa"; 
 
    /**
     * 密码
     */ 
    private static final String USERPASSWORD = "111111"; 
 
    /**
     * 创建数据库连接类
     */ 
    private Connection connnection = null; 
 
    /**
     * 创建操作对象
     */ 
    private Statement statement = null; 
 
    /**
     * 创建结果集对象
     */ 
    private ResultSet resultSet = null; 
     
    static { 
        try { 
            // 加载数据库驱动程序 
            Class.forName(DRIVER); 
        } catch (ClassNotFoundException e) { 
            System.out.println("加载驱动错误"); 
            System.out.println(e.getMessage()); 
        } 
    } 
 
    /**
     * 建立数据库连接
     * 
     * @return
     */ 
    public Connection getConnection() { 
        try { 
            // 获取连接 
            connnection = DriverManager.getConnection(URLSTR, USERNAME, 
                    USERPASSWORD); 
        } catch (SQLException e) { 
            System.out.println(e.getMessage()); 
        } 
        return connnection; 
    } 
 
    /**
     * insert update delete 统一的方法
     * 
     * @param sql
     *            insert,update,delete SQL 语句
     * @return 受影响的行数
     */ 
    public int executeUpdate(String sql) { 
        int affectedLine = 0; 
        try { 
            // 获得连接 
            connnection = this.getConnection(); 
 
            // 创建对象 
            statement = connnection.createStatement(); 
 
            // 执行SQL语句 
            affectedLine = statement.executeUpdate(sql); 
        } catch (SQLException e) { 
            System.out.println(e.getMessage()); 
        } finally { 
            // 释放资源 
            closeAll(); 
        } 
        return affectedLine; 
    } 
 
    /**
     * 查询数据库方法
     * 
     * @param sql sql语句
     *            
     * @return 结果集
     */ 
    private ResultSet executeQueryRS(String sql) { 
        try { 
            // 获得连接 
            connnection = this.getConnection(); 
 
            // 创建Statement对象 
            statement = connnection.createStatement(); 
 
            // 执行SQL 语句 
            resultSet = statement.executeQuery(sql); 
        } catch (SQLException e) { 
            System.out.println(e.getMessage()); 
        } 
        return resultSet; 
    } 
     
    /**
     * 获取结果集,并将结果放在List中
     * @param sql SQL语句
     * @return List结果集
     */ 
    public List<Object> excuteQuery(String sql) {  
        ResultSet rs = executeQueryRS(sql); 
        ResultSetMetaData rsmd = null; 
 &
补充:软件开发 , Java ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,