JDBC的学习之路(一)

使用sql要配置路径

首先到官网下载 http://dev.MySQL.com/downloads/connector/

因为是java与数据库连接,所以选择 Connector/J

 download -->(mysql-connector-java-5.1.43.tar.gz)   不用登陆,鼠标下滑到底端,选择No thanks,just start my download

-----------------版本下载自己想要的就行 -------------------

下载之后解压

然后在所在项目右键单击

选择  

Build Path-->Configure Build Path-->Libraries界面下,选择 Add External JARs-->找到mysql-connector-java-5.1.43-bin.jar位置选中后确定,ok,即可

Driver接口

----Driver接口由数据库厂家提供,对于java开发者而言,只需要使用Driver接口就可以啦

----在编程中要连接数据库,必须先装载特定厂家的数据库驱动程序,不同的数据库有不同的装载方法. 这里推荐下载Navicat for MySQL绿色版.官网下载,https://navicatformysql.en.softonic.com/     解压,配置,(配置中有一项,一般选择utf-8.......)       263

----驱动就是各个数据库厂商实现的Sun公司提供的JDBC接口,即对Connection等接口的实现类的jar文件

----装载MySQL驱动

　　　　　　--Class.forName("com.mysql.jdbc.Driver");

----装载Oracle驱动

　　　　　　--Class.forName("oracle.jdbc.driver.OracleDriver");

Connection接口

----Connection与特定数据库连接(会话),在连接上下文中执行SQL语句并返回结果.

----DriverManager的getConnection()方法建立在JDBC URL中定义的数据库Connection连接上

----连接MySQL数据库:

　　　　--Connection conn=DriverManager.getConnection("jdbc:mysql://host:port/database","user","password");

----连接ORACLE数据库:

　　　　--Connection conn=DriverManager.getConnection("jdbc:oracle:thin:@host:port:database","user","password");

package com.jxust.jdbc;
/**
 * 测试和数据库建立连接

 * 
 */
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;


public class Demo01 {

    //测试和数据库建立连接
    public static void main(String[] args) {
        Connection conn=null;
        try {
            //加载驱动类
            Class.forName("com.mysql.jdbc.Driver");
            long start=System.currentTimeMillis();
            //建立连接(连接对象内部其实包含了Socket对象,是一个远程的连接,比较耗时,这是Connection对象管理的一个要点)
            //在真正的开发中,为了提高效率,都会使用连接池管理连接对象
             conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc","root","*****");
            long end=System.currentTimeMillis();　　　　　　　//主机IP     端口/数据库名     user    密码
            System.out.println(conn);
            System.out.println("建立连接,耗时为:"+(end-start)+"ms毫秒");
            
        } catch (ClassNotFoundException | SQLException e) {
        
            e.printStackTrace();
        }
        finally{
            if(conn!=null){       //连接的关闭
                try {
                    conn.close();
                } catch (SQLException e) {
                    
                    e.printStackTrace();
                }
            }
        }
    }
}

 

package com.jxust.jdbc;

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


public class Demo02 {

    //测试Statement接口用法,执行SQL语句,以及SQL注入问题
    public static void main(String[] args) {
        Statement stmt=null;
        Connection conn=null;
        try {
            //加载驱动类
            Class.forName("com.mysql.jdbc.Driver");
            //建立连接(连接对象内部其实包含了Socket对象,是一个远程的连接,比较耗时,这是Connection对象管理的一个要点)
            //在真正的开发中,为了提高效率,都会使用连接池管理连接对象
             conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc","root","z****");
            System.out.println(conn);
             stmt=conn.createStatement();
//            String name="xiamu";
            //传参只能采用拼字符串的形式,很容易被遭到破坏
//            String sql="insert into t_user(username,pwd,regTime) values('"+name+"',555,now())";
//            String sql="insert into t_user(username,pwd,regTime) values('xiamu',555,now())";
//            stat.execute(sql);
            
            //测试SQL注入
            String id="5 or 1=1";
            String sql="delete from t-user where id="+id;  //永为true,数据库数据会被恶意改动,不安全,
//            String sql="delete from t_user where id=5";
            stmt.execute(sql);
            
        } catch (ClassNotFoundException | 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();
                }
            }
        }
    }
}

package com.jxust.jdbc;

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

/**
 * 测试PreparedStatement的基本用法
 */

//测试PreparedStatement的基本用法
public class Demo03 {

    
    public static void main(String[] args) {
        PreparedStatement ps=null;
        Connection conn=null;
        try {    //加载驱动类
            Class.forName("com.mysql.jdbc.Driver");
             conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc","root","z****");
            
            /**
             * ? 占位符,在输入对应值的时候会进行预处理,可以防止SQL注入
             */
            String sql="insert into t_user(username,pwd,regTime) values(?,?,?)";
             ps=conn.prepareStatement(sql);
//            ps.setString(1, "happy1");  //参数索引是从1开始计算,而不是0,
//            ps.setString(2, "123");   //根据row的属性不懂,选择不同的setXxx方法,setDate(),setDouble();.....
//            ps.setString(1, "happy2");  //继续插入happy2
//            ps.setString(2, "12456");
//            ps.setDate(3, new java.sql.Date(System.currentTimeMillis()));
            
            //也可以使用setObject方法处理参数,避免记各个类型的烦恼
            ps.setObject(1, "happy4");
            ps.setObject(2, "7889");
            ps.setObject(3, new java.sql.Date(System.currentTimeMillis()));  
                             //java.sql.Date是java.Util.Date的子类
            
            
            System.out.println("插入一行记录");
//            ps.execute();
            int count=ps.executeUpdate(); //executeUpdate  运行insert/update/delete操作,返回更新行数 executeQuery()  返回结果集对象
            System.out.println(count);
        } catch (ClassNotFoundException | SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            if(ps!=null){
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }    
    } 
}

package com.jxust.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

/**
 * 测试ResultSet接口的基本用法
 */


public class Demo04 {
/**
 * 测试ResultSet接口的基本用法
 * 依序关闭使用之对象及连接            ResultSet-->Statement-->Connection
 *                           一定要分开写(如果其中一个异常,要保证下面的也关闭,嵌套写就不会有这种效果)
 * @param args
 */    
    
    public static void main(String[] args) {
        PreparedStatement ps=null;
        Connection conn=null;
        ResultSet rs=null;
        try {    //加载驱动类
            Class.forName("com.mysql.jdbc.Driver");
             conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/testjdbc","root","****");
        
            String sql="select id,username,pwd from t_user where id>?";   //select*from....是返回所有的列
             ps=conn.prepareStatement(sql);
            ps.setObject(1, 2); //把id大于2的记录都取出来
            
             rs=ps.executeQuery();
            
            while(rs.next()){   //Iterator式迭代,每调用一次,next移动一位,同时返回一个判断下一个是否为空的boolean值
                System.out.println(rs.getInt(1)+"----"+rs.getString(2)+"----"+rs.getString(3));
            }
            
        } catch (ClassNotFoundException | SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            if(rs!=null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    
                    e.printStackTrace();
                }
            }
            if(ps!=null){
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    } 
}