Java中JDBC相关知识

Dear 丶 2022-09-25 11:27 13阅读 0赞

## 1. JDBC编程步骤 ##

> 1.  加载数据库驱动
> 2.  通过DriverManager获得数据库连接
> 3.  通过Connection对象创建Statement对象
> 4.  使用Statement执行SQL语句
> 5.  操作结果集
> 6.  回收数据库资源

//1.加载驱动
            Class.forName("com.mysql.jdbc.Driver");
            try (
                    //2.获取连接
                    Connection conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/ubuntu", "root", "123456");
                    //3.创建对象
                    Statement statement = conn.createStatement();
                    //4.执行操作
                    ResultSet resultSet = statement.executeQuery("SELECT * FROM users")) {
    
                while (resultSet.next()) {
                    System.out.println(resultSet.getInt(1) + "\t" + resultSet.getString(2) + "\t" + resultSet.getString(3));
                }

--------------------

## 2. 数据库操作 ##

>  *  执行了DDL语句后返回值为0，执行了DML语句后返回值为受影响的记录条数
>  *  Statement的execute()方法几乎可以执行任何SQL语句
>  *  使用execute()方法执行SQL语句的返回值是boolean值，它表明执行该SQL语句是否返回了ResultSet对象
>  *  ResultSet的getString()方法几乎可以获取除Blob之外的任意类型列的值，因为所有的数据类型都可以自id哦难怪转换成字符串类型
>  *  PreparedStatement可以防止SQL注入，安全性更好

*  使用Properties类加载属性文件

Properties config = new Properties();
            config.load(new FileInputStream(configFile));
            driver = config.getProperty("driver");
            url = config.getProperty("url");
            user = config.getProperty("user");
            pass = config.getProperty("pass");
            Class.forName(driver);
            Connection connection = DriverManager.getConnection(url, user, pass);

*  配置文件mysql.ini：

#comment line
        #Mon Aug 15 21:08:18 CST 2016
        driver=com.mysql.jdbc.Driver
        url=jdbc:mysql://127.0.0.1:3306/ubuntu
        user=root
        pass=123456

--------------------

## 3. RowSet ##

>  *  RowSet默认是可滚动的、可更新的、可序列化的结果集，可以作为JavaBean使用  
>     
>     
>      *  离线RowSet可以把数据从底层数据库读取到内存中，封装成RowSet对象
>      *  可以通过acceptChanges()方法将程序对RowSet做的修改同步到底层数据库

public class CachedRowSetTest {
            public CachedRowSet query(String sql) throws SQLException, IOException, ClassNotFoundException {
            Connection conn = ConnMySQL.getConnection("mysql.ini");
            Statement statement = conn.createStatement();
            ResultSet set = statement.executeQuery(sql);
    
            RowSetFactory factory = RowSetProvider.newFactory();
            CachedRowSet cachedRowSet = factory.createCachedRowSet();
            cachedRowSet.populate(set);
    
            set.close();
            statement.close();
            conn.close();
            return cachedRowSet;
            }
    
            public static void main() throws SQLException, IOException, ClassNotFoundException {
            CachedRowSetTest cachedRowSetTest = new CachedRowSetTest();
            CachedRowSet rowSet = cachedRowSetTest.query("select * from my_test");
            rowSet.afterLast();
            while (rowSet.previous()) {
                System.out.println(rowSet.getString(1) + "\t" + rowSet.getString(2) + "\t" + rowSet.getString(3));
                if (rowSet.getInt("id") == 1) {
                    rowSet.updateString("name", "Ying");
                    rowSet.updateRow();
                }
            }
            //用于将数据从离线的Rowset中提交到数据库
            Connection connection = ConnMySQL.getConnection("mysql.ini");
            connection.setAutoCommit(false);
            rowSet.acceptChanges(connection);
            }
        }

*  使用分页查询  
    
    
     *  分页查询就是一次只装载ResultSet里的某几条记录

public class CachedRowSetPage {
            public CachedRowSet query(String sql,int pageSize,int page) {
            try (Connection conn = ConnMySQL.getConnection("mysql.ini");
                 Statement statement = conn.createStatement();
                 ResultSet resultSet = statement.executeQuery(sql)) {
    
                RowSetFactory factory = RowSetProvider.newFactory();
                CachedRowSet cachedRowSet = factory.createCachedRowSet();
    
                cachedRowSet.setPageSize(pageSize);
                cachedRowSet.populate(resultSet, (page - 1) * pageSize + 1);
    
                return cachedRowSet;
    
            } catch (IOException e) {
                e.printStackTrace();
            } catch (SQLException e) {
                e.printStackTrace();
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            }
            return null;
            }
    
            public static void main(String[] args){
                CachedRowSetPage page = new CachedRowSetPage();
                CachedRowSet set = page.query("select * from my_test",3,2);
                while (set.next()) {
                    System.out.println(set.getString(1)+"\t"+set.getString(2)+"\t"+set.getString(3));
                }
            }
        }

--------------------

## 4. 事务 ##

>  *  开启事务：set autocommit=0;  
>     
>     
>      *  开启事务后不会自动提交，该命令窗口内的所有DML语句不会立即生效
>      *  临时性的开启事务可以使用start transaction 或者 begin，之后的DML不会立即生效，除非显式的使用commit或执行DDL、DCL来隐式的提交事务
>      *  不论是显式提交还是隐式提交都会结束当前事务
>      *  不论显式回滚还是隐式回滚，都会结束当前事务
>      *  回滚到指定中间点因为依然处于事务之中，所以不会结束当前事务
>  *  批量更新  
>     
>     
>      *  addBatch()方法将多条SQL语句收集起来，然后一起执行
>      *  如果在addBatch()中添加了Select语句，将会出现错误
>      *  执行executeLargeBatch()会返回一个long\[\] 数组

Statement stmt = conn.createStatement();
         stmt.addBatch(sql1);
         stmt.addBatch(sql2);
         stmt.addBatch(sql3);
         ...
         stmt.excuteLargeBatch();

--------------------

## 5. 连接池 ##

>  *  DBCP数据源  
>     
>     
>      *  需要commons-dbcp.jar 和 commons-pool.jar
>      *  [http://commons.apache.org][http_commons.apache.org]

//创建数据源对象
        BasicDataSource ds = new BasicDataSource();
        //设置连接池所需的驱动
        ds.setDriverClassName("com.mysql.jdbc.Driver");
        //设置连接数据库的URL
        ds.setUrl("jdbc:mysql//localhost:8080/database");
        //设置连接数据库用户名
        ds.setUsername("root");
        //设置数据库连接密码
        ds.setPassword("pass")
        //设置连接池的初始连接数
        ds.setInitialSize(5);
        //设置连接池最多可以有多少个活动连接数
        ds.setMaxActive(20);
        //设置连接池中最少有两个连接
        ds.setMinIdle(2);
    
        //通过数据源获取数据库连接
        Connection conn = ds.getConnection();
        //释放数据库连接(仅仅释放连接，归还给连接池，并没有关闭物理连接)
        conn.close();

>  *  C3P0数据源  
>     
>     
>      *  可以自动清理不再使用的Connection，还可以清理Statement和ResultSet
>      *  [http://sourceforge.net/projects/c3p0/][http_sourceforge.net_projects_c3p0]

//创建数据源对象
        ComboPooledDataSource ds = new ComboPooledDataSource();
        //设置连接池所需的驱动
        ds.setDriverClass("com.mysql.jdbc.Driver");
        //设置连接数据库的URL
        ds.setJdbcUrl("jdbc:mysql//localhost:8080/database");
        //设置连接数据库用户名
        ds.setUser("root");
        //设置数据库连接密码
        ds.setPassword("pass")
        //设置连接池的初始连接数
        ds.setInitialPoolSize(5);
        //设置连接池最多可以有多少个活动连接数
        ds.setMaxPoolSize(20);
        //设置连接池中最少有两个连接
        ds.setMinPoolSize(2);
        //设置连接池的缓存Statement的最大数
        ds.setMaxStatements(100);
    
        //通过数据源获取数据库连接
        Connection conn = ds.getConnection();

[http_commons.apache.org]: http://commons.apache.org
[http_sourceforge.net_projects_c3p0]: http://sourceforge.net/projects/c3p0/