mysql 第三课 jdbc基础操作

jdbc连接可以大致分为5步：

1.注册驱动

2.获取连接

3.编写语句

4.执行语句

5.关闭连接

其中可以设置参数等等。

1.我们先建一个项目目录：

其中com.etc.dao为数据访问对象

com.etc.config 为配置文件的获取键值

com.etc.domain是实现包

com.etc.util是工具包

db.properties是配置文件

2.先写一个配置文件 db.properties 和相应的使用文件 JDBCConfig.java

mysql.Driver=com.mysql.jdbc.Driver
mysql.url=jdbc:mysql://127.0.0.1:3310/day02
mysql.username=root
mysql.password=123456

package com.etc.config;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.util.Properties;

public class JDBCConfig {
    public static String driver;
    public static String url;
    public static String username;
    public static String password;
    //必须使用静态代码块 优先加载 不然可能会报空指针异常
    static {
        //配置文件获取值
        Properties pro = new Properties();
        try {    
            //通过FileInputStream读文件
            pro.load(new FileInputStream(new File("src/db.properties")));
            //通过键获取值
            driver = pro.getProperty("mysql.Driver");
            url = pro.getProperty("mysql.url");
            username = pro.getProperty("mysql.username");
            password = pro.getProperty("mysql.password");
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

2.编写用户类 UserDao.java

package com.ect.dao;

public class UserDao {
    private int id;
    private String name;
    
    
    public UserDao() {
        super();
    }


    public UserDao(int id, String name) {
        super();
        this.id = id;
        this.name = name;
    }


    @Override
    public String toString() {
        return "UserDao [id=" + id + ", name=" + name + "]";
    }


    public int getId() {
        return id;
    }


    public void setId(int id) {
        this.id = id;
    }


    public String getName() {
        return name;
    }


    public void setName(String name) {
        this.name = name;
    }
    
    
}

3.编写工具类 JDBCUtil.java

package com.etc.Util;

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

import com.etc.config.JDBCConfig;

public class JDBCUtil {

    static Connection conn = null;
    static PreparedStatement st = null;

    /**
     * 获取连接
     * 
     * @return
     */
    public static Connection getConnection() {
        try {
            // 注册驱动
            Class.forName(JDBCConfig.driver);
            // 连接数据库，传入库，账号，密码
            conn = DriverManager.getConnection(JDBCConfig.url, JDBCConfig.username, JDBCConfig.password);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }

    /**
     * 关闭连接
     * 
     * @param st
     */
    public static void close(Connection conn, PreparedStatement st, ResultSet rs) {
        closeRs(rs);
        closeSt(st);
        closeConn(conn);
    }

    public static void closeConn(Connection conn) {
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void closeSt(PreparedStatement st) {

        if (st != null) {
            try {
                st.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void closeRs(ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

    }
}

4.编写CURD语句 JDBCDml.java

package com.etc.Util;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.ect.dao.UserDao;

public class JDBCDml {
    /**
     * 查询语句
     * 
     * @param sql
     * @return
     */
    // 查询语句 因为我们建立的是User表 传出来的值是对象 所以我们用一个集合来存储
    public static List<UserDao> select(String sql) {
        List<UserDao> list = new ArrayList<>();
        Connection conn = null;
        PreparedStatement st = null;
        ResultSet rs=null;
        try {
            // 注册驱动与获取连接
            conn = JDBCUtil.getConnection();
            // 执行语句
            st = conn.prepareStatement(sql);
            // 结果集
            rs = st.executeQuery();
            // 获取每一个对象和相对应的值
            while (rs.next()) {
                int userid = rs.getInt("sid");
                String username = rs.getString("name");
                // 将值传给ud
                UserDao ud = new UserDao(userid, username);
                // 添加到集合
                list.add(ud);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 关闭连接
            JDBCUtil.close(conn,st,rs);
        }
        return list;

    }

    // 传一个对象用此方法
    // public static ResultSet insert(UserDao ud) {
    /**
     * 插入语句
     * 
     * @param sql
     * @param pramas
     * @return
     */
    public static ResultSet insert(String sql, Object... pramas) {
        Connection conn = null;
        PreparedStatement st = null;
        ResultSet rs = null;
        try {
            conn = JDBCUtil.getConnection();
            // 创建语句
            st = conn.prepareStatement(sql);
            // 设置参数
            for (int i = 0; i < pramas.length; i++) {
                st.setObject(i + 1, pramas[i]);
            }
            // 设置参数，这是如果你需要传的是user对象则直接可以用get方法获取其相对应的值
            // st.setInt(1,ud.getId());
            // st.setString(2,ud.getName());
            // 执行语句
            st.executeUpdate();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭连接
            JDBCUtil.close(conn,st,rs);
        }
        return rs;

    }
    // 传一个对象用此方法
    // public static void update(UserDao ud){

    /**
     * 更新语句
     * 
     * @param sql
     * @param pramas
     */
    public static void update(String sql, Object... pramas) {
        Connection conn = null;
        PreparedStatement st = null;
        try {
            // 注册驱动与获取连接
            conn = JDBCUtil.getConnection();
            // 执行语句
            st = conn.prepareStatement(sql);
            // 设置参数
            for (int i = 0; i < pramas.length; i++) {
                st.setObject(i + 1, pramas[i]);
            }
            // 设置参数
            // st.setString(1,ud.getName());
            // st.setInt(2,ud.getId());
            st.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 关闭连接
            JDBCUtil.closeSt(st);
            JDBCUtil.closeConn(conn);
        }
    }

    /**
     * 删除语句
     * 
     * @param sql
     * @param pramas
     */
    // public static void delete(UserDao ud) {
    public static void delete(String sql, Object... pramas) {
        Connection conn = null;
        PreparedStatement st = null;
        try {
            // 注册驱动与获取连接
            conn = JDBCUtil.getConnection();
            // 执行语句
            st = conn.prepareStatement(sql);
            // 设置参数
            for (int i = 0; i < pramas.length; i++) {
                st.setObject(i + 1, pramas[i]);
            }
            // 设置参数
            // st.setInt(1, ud.getId());
            st.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 关闭连接
            JDBCUtil.closeSt(st);
            JDBCUtil.closeConn(conn);
        }
    }
}

5.编写测试类 JDBCDemo.java

package com.etc.domain;

import java.util.List;

import com.ect.dao.UserDao;
import com.etc.Util.JDBCDml;


public class JDBCDemo {

    public static void main(String[] args) {
        //JDBCDml.insert("insert into sanguo (sid,name) values (?,?)","2","adaasd");
        //JDBCDml.update("update sanguo set name=(?) where sid=(?)","awerq",2);
        //JDBCDml.delete("delete from sanguo where sid=?",2);
        
        List<UserDao> list = JDBCDml.select("select * from sanguo");
        for (UserDao sanGuo : list) {
            System.out.println(sanGuo);
        }
            
        //User();
    }

    private static void User() {
        UserDao ud = new UserDao();
        ud.setId(4);
        ud.setName("aa5453a");
        
        //JDBCDml.insert(ud);
        //JDBCDml.update(ud);
        //JDBCDml.delete(ud);
    }

}

完成。现在只是自己写的连接 一些连接池啊 什么的都没有完成  等以后再更新。

需要把时间字段类型设置为“timestamp”，然后再在默认值中填写“CURRENT_TIMESTAMP”