java之jdbc_采用Statement添加数据

动力节点笔记

 

import java.sql.*;
//采用Statement添加数据
public class InsertTest01 {
    public static void main(String[] args) {
        if (args.length != 8) {
            throw new IllegalArgumentException("参数非法，正确使用为InsertTest01 ...");
        }

        Connection conn = null;
        Statement stmt = null;
        try {
            //第一步，加载数据库驱动，不一样的数据库驱动程序不同
            Class.forName("oracle.jdbc.driver.OracleDriver");
            //第二部，获得数据库链接
            String dburl = "jdbc:oracle:thin:@localhost:1521:orcl";
            //String dburl = "jdbc:oracle:thin:@192.168.21.1:1521:orcl";
            //String dburl = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
            String userName = "system";
            String password = "wanwan";
            conn = DriverManager.getConnection(dburl, userName, password);
            //System.out.println(conn);


            int empno = Integer.parseInt(args[0]);
            String ename = args[1];
            String job = args[2];
            int mgr = Integer.parseInt(args[3]);
            //格式：yyyy-mm-dd
            String hiredate = args[4];
            float sal = Float.parseFloat(args[5]);
            float comm = Float.parseFloat(args[6]);
            int deptno = Integer.parseInt(args[7]);

            //第三步，建立Statement，执行SQL语句
            //拼串
            //最好将比较复杂的sql调通，再将sql语句和程序相结合，进行连调
            String sql = "insert into enp(empno, ename, job, mgr, hiredate, sal, comm, deptno) ";

            sql += "values("+ empno +", '"+ ename +"', '"+ job +"', "+ mgr +", ";
            sql += "to_date('"+ hiredate +"', 'yyyy-mm-dd'), "+ sal + ", "+ comm +", "+ deptno +")";

            System.out.println("sql = " + sql);
            stmt = conn.createStatement();
            stmt.executeUpdate(sql);
            System.out.println("添加员工成功");



        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //注意关闭原则：从里到外
            try {
                if (stmt != null) {
                    stmt.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch(SQLException e) {

            }

        }
    }
}