首页 > 技术文章 > JDBC

zhuwenxia 2018-09-21 15:15 原文

/**
     * jdbc建立数据库连接
     */
    public static void main(String[] args)  {
        try {
            //1.注册驱动
            //DriverManager.registerDriver(new com.mysql.jdbc.Driver());
        Class.forName("com.mysql.jdbc.Driver");
//2.建立连接 Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/test", "root", "123456"); //3.创建statement Statement st = conn.createStatement(); //4.执行查询 String sql = "select * from tt_test"; ResultSet rs = st.executeQuery(sql); //5.遍历查询每一条数据 while(rs.next()){ String name = rs.getString("name"); int age = rs.getInt("age"); System.out.println("name="+name+"--------"+"age="+age); } rs.close(); st.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } } }
/**
     * jdbc使用properties配置文件连接
     */
    public static void main(String[] args) throws IOException {
        String driverClass;
        String url;
        String name;
        String password;
        //1.创建一个属性配置对象
        Properties properties = new Properties();

      //对应文件位于工程根目录
      InputStream is = new FileInputStream("jdbc.properties");

//使用类加载器,去读取src底下的资源文件(对应文件位于src目录下)
        InputStream is = Test2.class.getClassLoader().getResourceAsStream("jdbc.properties");
        //导入输入流
        properties.load(is);
        //读取属性
        driverClass = properties.getProperty("driverClass");
        url = properties.getProperty("url");
        name = properties.getProperty("name");
        password = properties.getProperty("password");
        try {
            //1.注册驱动
            //DriverManager.registerDriver(new com.mysql.jdbc.Driver());
            Class.forName(driverClass);
            //2.建立连接
            Connection conn = DriverManager.getConnection(url, name, password);
            //3.创建statement 
            Statement st = conn.createStatement();
            //4.执行查询
            String sql = "select * from tt_test";
            
            ResultSet rs = st.executeQuery(sql);
            //5.遍历查询每一条数据
            while(rs.next()){
                String name1 = rs.getString("name");
                int age = rs.getInt("age");
                System.out.println("name="+name1+"--------"+"age="+age);
            }
            rs.close();
            st.close();
            conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

 

public void testInsert() throws Exception{
        Class.forName("com.mysql.jdbc.Driver");
        Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/test", "root", "123456");
        Statement st = conn.createStatement();
        //插入、删除、更新类似
        String sql = "insert into tt_test (name,age) VALUES('eee',22)";
        int result = st.executeUpdate(sql);
        if(result > 0){
            System.out.println("添加成功");
        }
    }

 

推荐阅读