java语言入门（四）JDBC技术和数据访问（9）

系统管理员 2022-05-26 04:05 101阅读 0赞

> jdbc 及时 java database connection java数据库连接  
> 本节以mysql数据库为例 连接mysql数据库并且执行操作  
> 前提你得会数据库

### 1.0 环境配置 ###

eclipse   mysql驱动的jar包  jdk1.8  mysql数据库

### 2.0 基本步骤 ###

1.  加载mysql驱动
2.  使用驱动管理连接数据库，返回数据库的连接 Connection对象
3.  用Connection对象创建sql语句，返回statement语句对象
4.  用statement对象执行sql语句
    
    1.  如果是查询 用statement.executQuery();
    2.  其余的操作例如 增删改 用 statement.executeUpdate();
5.  关闭语句流
6.  关闭数据库连接

具体代码如下

package com.ccut.connect;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.SQLException;
    //因为需要经常连接数据库 所以我把数据库的连接单独写在一个类中，省事 代码的简单复用
    public class Connect_database { 
    
        public Connection getConnection(){
            Connection con = null;
            try {
                //加载驱动
                Class.forName("com.mysql.jdbc.Driver");
                //链接数据库 返回数据库连接
                con = DriverManager.getConnection("jdbc:mysql://localhost:3306/xyd","root","xuyandong");
            } catch (ClassNotFoundException e) {
                // TODO Auto-generated catch block
                System.out.println("驱动包加载失败");
                e.printStackTrace();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                System.out.println("数据库连接失败");
                e.printStackTrace();
            }
            return con;     
        }
    }
    //这是下一个类
    package com.ccut.executesql;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    
    import com.ccut.connect.Connect_database;
    
    public class Executesql { 
        void insertDate(String sql){
            Connection con;
            Connect_database connect_database = new Connect_database();
            con = connect_database.getConnection();//获取数据库的连接
            try {
                //sql语句处理
                //数据库预处理语句相对于statement 可以有效的防止sql注入攻击 但是进行批处理的时候不行
                PreparedStatement ps= con.prepareStatement(sql);
                //下面是执行sql语句
                ps.execute();
                } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println("ok");
        }
    
        public static void main(String[] args) {
            Executesql executesql =  new Executesql();
            executesql.insertDate("insert into t(id,name) values('5','word')");
        }
    
    }

结果  
控制台  
![这里写图片描述][70]  
数据库  
![这里写图片描述][70 1]

这里注意

void insertDate(String sql){
            Connection con;
            Connect_database connect_database = new Connect_database();
            con = connect_database.getConnection();//获取数据库的连接
            try {
                //sql语句处理
                //数据库预处理语句相对于statement 可以有效的防止sql注入攻击 但是进行批处理的时候不行
                PreparedStatement ps= con.prepareStatement(sql);
                //下面是执行sql语句
                ps.execute();
                } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println("ok");
        }
    
    //这里面一般实际应用上我们传的参数一般不是sql 而是数值 一般如下
    
    
    void insertDate(String name,int id){
            Connection con;
            Connect_database connect_database = new Connect_database();
            con = connect_database.getConnection();//获取数据库的连接
            /***********************************************************************/
            //注意下面的变化 ?? 分别是占位符 执行的时候会被相应的句子所替换
            String sql = "insert into t(id,name) values(?,?)";
            /************************************************************************/
            try {
                //sql语句处理
                //数据库预处理语句相对于statement 可以有效的防止sql注入攻击 但是进行批处理的时候不行
                PreparedStatement ps= con.prepareStatement(sql);
                /****************************************************************/
                //上面的占位符就是被下面这两句话所替代 其中1 代表第一个占位符 因为第一个占位符
                //是需要整型的数 所以用setInt() 如果是字符型的用setChar() 其他的以此类推
                // 1 ，id 的意思是第一个占位符用 id 的值替换 如果id = 5 name = "h" 那么
                //sql语句就变为了insert into t(id,name) values(5,'h');数据库字符串的用单引号
                ps.setInt(1,id);
                ps.setString(2,name);
    
                /****************************************************************/
                //下面是执行sql语句
                ps.execute();
                } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println("ok");
        }

--------------------

我们再说一下怎么用statement

package com.ccut.executesql;
    
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    import com.ccut.connect.Connect_database;
    
    
    public class Executesql {
        void insertDate(){
            Connection con;
            Connect_database connect_database = new Connect_database();
            con = connect_database.getConnection();
            try {
                //sql语句处理
                Statement statement = con.createStatement();
                //从t表查询所有信息 返回给ResultSet对象接收
                ResultSet rs = statement.executeQuery("select * from t");
                //我们把结果读出来  rs代表游标  初始时候指向结果集合的最前面  
                //执行一次rs.next()的时候游标前移 返回true  如果没有数据返回的是false
                //例如本次结果
                /* * rs 最开始的位置 * * * 执行一次rs.next() 首先判断吓一跳数据存在不 存在返回true rs执行这个记录-》 id = 2 name = xyd rs-> id = 5 name = word rs.next() 不存在记录了 返回false * */
                while(rs.next()){
                    //1 代表数据库表的第一列  2 代表第二列
                    System.out.println("id = "+rs.getInt(1)+"name = "+rs.getString(2));
                    //第二种读取返回数据的方法  读数据库表对应的列的名字
                    System.out.println("id = "+rs.getString("id")+"name = "+rs.getString("name"));
                }
                } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println("ok");
        }
    
        public static void main(String[] args) {
            Executesql executesql =  new Executesql();
            executesql.insertDate();
        }
    
    }

> 基本就这样 剩下的用的时候在百度查就ok了

[70]: /images/20220526/c6e62f8091554dd1b8ad8fce85cf2a0a.png
[70 1]: /images/20220526/ae2e18737b4242bfb7601815e55cf94a.png