jdbctraining.java

一个小例子对入学者使用用的是JAVA的基本知识

package page;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;

public class JDBCTraining {

    @SuppressWarnings("unchecked")
    public static void main(String[] args) {
        System.out.println("开始创建连接....");
        //String sql = "select * from categories where categoryid=?";
        // System.out.println(query(sql, new Object[]{new Integer(1)}));
        //sql = "select * from products";
        // ArrayList list = query(sql, new Object[]{});
        // for (Object row : list) {
        // System.out.println(row);
        // }
        // System.out.println(list.size());
    }

    private static Connection createConn() {
        // 驱动名
        String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
        // 连接地址
        String url = "jdbc:sqlserver://localhost:1433;databaseName=students";
        // 用户名
        String user = "sa";
        // 密码
        String password = "sa";
        try {
            // 加载驱动
            Class.forName(driver);
            // 创建连接
            return DriverManager.getConnection(url, user, password);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }

    @SuppressWarnings("unchecked")
    public static ArrayList query(String sql, Object... argus) {
        // 定义返回的集合对象
        ArrayList list = new ArrayList();
        // 调用连接
        Connection conn = createConn();
        ResultSet rs = null;
        PreparedStatement prst = null;
        try {
            // 准备执行SQL
            prst = conn.prepareStatement(sql);
            // 设定SQL中的参数
            for (int i = 0; i < argus.length; i++) {
                prst.setObject(i + 1, argus[i]);
            }
            // 执行查询
            rs = prst.executeQuery();
            // 获取查询结果中包含的字段的信息，包括字段数量，名称，数据类型。
            ResultSetMetaData rsmd = rs.getMetaData();
         
            // 查询语句中包含的字段的数量
            int columnCount = rsmd.getColumnCount();
            HashMap map = null;
            while (rs.next()) {
                // 一条记录对应一个hashmap对象
                map = new HashMap();
                for (int i = 0; i < columnCount; i++) {
                    map.put(rsmd.getColumnName(i + 1).toLowerCase(), rs.getObject(i + 1));
                }
                
                // 把每个HashMap对象存入集合对象中返回。
                //OrderBean bean = new OrderBean();
                //bean.setOrderId(rs.getInt("ORDERID"));
                //bean.setName(rs.getString("NAME"));
                
                //list.add(bean);
                list.add(map);
            }
        } catch (SQLException e) {
            // 异常处理
            e.printStackTrace();
        } finally {
            // 关闭资源（注意关闭顺序）
            try {
                rs.close();
                prst.close();
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return list;
    }

    @SuppressWarnings("unused")
    public static int update(String sql, Object... argus) {
        // 调用连接
        Connection conn = createConn();
        PreparedStatement prst = null;
        try {
            // 准备执行SQL
            prst = conn.prepareStatement(sql);
            // 设定SQL中的参数
            for (int i = 0; i < argus.length; i++) {
                prst.setObject(i + 1, argus[i]);
            }
            // 执行更新
            return prst.executeUpdate();

        } catch (SQLException e) {
            e.printStackTrace();
            return 0;
        } finally {
            // 关闭资源
            try {
                prst.close();
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}