新手学JAVA（八）----走进JDBC

import java.sql.*; //导入包
import java.sql.Connection;
import java.sql.DriverManager;

public class JDBCMain {

    // 数据库的链接
    private Connection con = null;
    private Statement st = null; // 执行SQL语句的对象
    private ResultSet rs = null; // 结果集对象

    public JDBCMain() {

        // 桥连接
        try {

            // 声明驱动程序
            String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";

            // users就是数据源的名称
            String ds = "jdbc:sqlserver://localhost:1433;databaseName=JavaSpecial";

            // 数据源的登录名
            String user = "sa";

            // 数据源的密码
            String password = "123456";

            // 链接数据库
            Class.forName(driver); // 加载数据库的驱动程序

            con = DriverManager.getConnection(ds, user, password);

            if (con != null) {

                System.out.println("数据库链接成功！");
            }
        } catch (Exception e) {
            System.out.println("数据库连接失败！" + e.toString());
        }
    }



    /**
     * 普通查询
     * @param sqlQuery
     */
    public void query(String sqlQuery) {

        try {
            // Connection con = null;
            Statement st = con.createStatement(); // 得到Statement的实例
            ResultSet rs = st.executeQuery(sqlQuery); // 执行SQL语句，返回结果集

            // 当返回的结果集不为空是，并且还有记录时
            while (rs != null && rs.next()) {
                int stu_num = rs.getInt(1); // 获得当前记录的第1个字段的值
                String name = rs.getString("name"); // 获得当前记录中"name"字段的值
                int age = rs.getInt("age"); // 获得当前记录中"age"字段的值
                int math = rs.getInt("math"); // 获得当前记录中"math"字段的值
                int english = rs.getInt("english"); // 获得当前记录中"english"字段的值

                System.out.println("学号=" + stu_num + "\t 姓名=" + name + "\t 年龄="
                        + age + "\t 数学成绩=" + math + "\t 英语成绩=" + english);
            }

        } catch (Exception e) {
            // 抛出异常
            System.out.println("查询数据时出错" + e.toString());
        }
    }

    /**
     * /添加，删除，更新
     */
    public void add_update_Del(String sql) {
        try {
            Statement st = con.createStatement(); // 生成Statement对象
            int x = st.executeUpdate(sql); // 执行操作
            System.out.println("操作成功" + x);
        } catch (Exception e) {
            System.out.println("数据修改时有误" + e.toString());
        }

    }

    // 主程序
    public static void main(String[] args) {

        JDBCMain jc = new JDBCMain();

        // 查询
        String name = "张三";
        String sqlQuery = "select * from stu_info where name='" + name + "'";
        jc.query(sqlQuery);

        //添加
        String sqlAdd ="insert into stu_info values(7,'令仔',17,89,84)";
        jc.add_update_Del(sqlAdd);

        //更改
        String sqlUpdate ="update stu_info set math =95 where name ='张三'";
        jc.add_update_Del(sqlUpdate);

        //删除
        String sqlDelete ="delete from stu_info where name='张三'";
        jc.add_update_Del(sqlDelete);
    }
}