代码详解

package jdbcDemo;

import java.sql.Statement;

import javax.naming.spi.DirStateFactory.Result;

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

public class ConnectJdbc {

    Connection conn =null;
    public static void main(String[] args) throws Exception {
        ConnectJdbc  cj = new ConnectJdbc();
        cj.getCon();

        //新增表
        //cj.addTable();

        //删除表
//      cj.deleteTable();

//      查询
        cj.queryData();

        //删除
        //cj.deleteData(4456);

        //更新
        //cj.updateData(4456);

        //新增
        //cj.addData(4467, "Jake",5000);
        cj.closeCon();

    }

    //连接数据库
    public Connection getCon() throws Exception {

        //加载驱动
        Class.forName("oracle.jdbc.OracleDriver");
        //获得连接
        //参数1  数据库地址
        //参数2 数据库用户名
        //参数3 密码
        conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl",
                "scott","root");
        return conn;

    }

    //关闭数据库连接
    public void closeCon() throws Exception {
        conn.close();
    }

    //新增表
    public void addTable() throws Exception {
        // 创建Statement对象   此对象帮我们执行sql
        Statement st = conn.createStatement();
        //写sql
        String sql = "create table utable(name varchar(20),pwd char(6))";
        //执行新增表语句,返回值为0
        int rs = st.executeUpdate(sql); 
        System.out.println(rs);
        if(rs==0) {
            System.out.println("创建用户表成功");
        }
    }

    //删除表
    public void deleteTable() throws Exception {
        // 创建Statement对象   此对象帮我们执行sql
        Statement st = conn.createStatement();
        //写sql
        String sql = "drop table utable";
        //执行删除表语句,返回值为0
        int rs = st.executeUpdate(sql); 
        System.out.println(rs);
        if(rs==0) {
            System.out.println("用户表删除成功");
        }
    }

    //查询
    public void queryData() throws Exception {

        // 创建Statement对象   此对象帮我们执行sql
        Statement st = conn.createStatement();

        //写sql
        String sql = "select * from emp";

        //查询,返回结果集，存放返回的数据集合
        ResultSet rs = st.executeQuery(sql);    
        while(rs.next()) {
            //取出一个字段，由于表中的empno为number,所以调用getInt()
            //由于ename为varchar2,所以调用getString()
            System.out.println(rs.getInt("empno")+" "+rs.getString("ename"));
        }
    }

    //删除
    public void deleteData(int id) throws Exception {

        // 创建Statement对象   此对象帮我们执行sql
        Statement st = conn.createStatement();
        //写sql
        String sql = "delete from emp where empno="+id;
        //删除，返回值为删除的行数
        int rs = st.executeUpdate(sql); 
        if(rs>0) {
            System.out.println("删除成功");
        }
    }

    //更新
    public void updateData(int id) throws SQLException {
        // 创建Statement对象   此对象帮我们执行sql
        Statement st = conn.createStatement();
        //写sql

        String sql = "update emp set sal=5000 where empno="+id;
        //更新的行数
        int rs = st.executeUpdate(sql); 
        if(rs>0) {
            System.out.println("更新成功");
        }

    }

    //新增
    public void addData(int empno,String ename,double salary) throws Exception {
        // 创建Statement对象   此对象帮我们执行sql
        Statement st = conn.createStatement();  
        //写sql
        String sql = "insert into emp(empno,ename,sal) values("+empno+",'"+ename+"',"+salary+")";
        //新增的行数
        int rs = st.executeUpdate(sql); 
        if(rs>0) {
            System.out.println("新增成功");
        }
    }

}

JDBC

JDBC 数据库连接技术
java database connectivity

使用数据库连接技术，需要jar包
java 可以连接不同的数据库，但连接不同的数据库需要不同的jar包

eclipse导入jar包

1.在java项目中连接JDBC
1.新建java project项目，在该项目下建个文件夹，我的是jar，然后把jar包放入该文件夹下

2.把jar包导入java项目

导入成功

2.在web项目中，导入jar包

add to path后生成这个refered libraries文件夹