JDBC学习

JDBC的本质理解

1.JDBC是什么?

Java Database Connectivity(Java语言连接数据库)

2.JDBC的本质是什么?

JDBC是SUN公司定制的一套接口(interface)
接口都有调用者和实现者
面向接口调用,面向接口写实现类,这都属于面向接口编程。
java.sql.*

为什么要面向接口编程?

 解耦合:降低程序的耦合度,提高程序的扩展力
 多态机制就是非常典型的:面向抽象编程。
 Animal a = new Cat();
 Animal b = new Dog();
 public void feed(Animal a){}

为什么要制定JDBC接口?

因为每一个数据库都有自己独特的实现原理。
驱动:就是一个jar包,所有的数据库驱动都是jar包的形式存在,jar包中有很多.class文件,这些.class文件就是对JDBC接口的实现。驱动不是SUN公司提供的,是各大数据库厂商提供,要到各个厂商官网中下载。

JDBC编程六步(背会)

第一步:注册驱动(告诉java程序即将连接的是哪个品牌的数据库)
第二部:获取连接(表示JVM的进程和数据库进程之间的通道打开了)
第三步:获取数据库操作对象(专门执行SQL语句的对象)
第四步:执行SQL语句(DQL,DML…)
第五步:处理查询结果集(只有当第四步是select语句时,才有这步)
第六步:释放资源(使用完资源之后一定要关闭资源)
插入

package JDBCStudy;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class Test1 {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/people","用户名","密码");
            stmt = conn.createStatement();
            String sql = "insert into user values(10,'123','123')";
            int result = stmt.executeUpdate(sql);
            System.out.println("影响的条数是:" + result);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if(stmt!=null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }


        }
    }
}

查询

getString(1)方法,无论数据库中是什么,取出来的都是String类型,参数是下标也就是第几列,下标从1开始,不是从0开始。
getString(“名字”)方法 通过列名称来查询(查询语句中的列名)
getInt() ...
package JDBCStudy;

import java.sql.*;

public class Test1 {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/people","用户名","密码");
            stmt = conn.createStatement();
            String sql = "select * from user";
            rs = stmt.executeQuery(sql);
            while(rs.next()){
                int id = rs.getInt("id");
                String password = rs.getString("password");
                String name = rs.getString("userName");
                System.out.println("id: " + id + ",name: " + name +  ",password " + password);
            }


        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if(stmt!=null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }


        }
    }
}

"+内容+"

SQL注入问题

如果需要SQL注入用Statement,如果想给SQL语句传值,用PreparedStatement

使用PrepareStatemnet完成增删改操作

package JDBCStudy;

import java.sql.*;

public class Test2 {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/people","用户名","密码");
            String sql = "select * from user where id = ?";
            ps = conn.prepareStatement(sql);
            ps.setInt(1,1);
            rs = ps.executeQuery();
            //System.out.println(rs);
            while(rs.next()){
                int id = rs.getInt("id");
                String password = rs.getString("password");
                String name = rs.getString("userName");
                System.out.println("id: " + id + ",name: " + name +  ",password " + password);
            }


        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(ps!=null){
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(rs!=null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

上一篇:Java IO流


下一篇:IO(老杜)