Java中JDBC相关知识

本文主要是介绍Java中JDBC相关知识，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

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 2016driver=com.mysql.jdbc.Driverurl=jdbc:mysql://127.0.0.1:3306/ubuntuuser=rootpass=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

    //创建数据源对象BasicDataSource ds = new BasicDataSource();//设置连接池所需的驱动ds.setDriverClassName("com.mysql.jdbc.Driver");//设置连接数据库的URLds.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/

//创建数据源对象ComboPooledDataSource ds = new ComboPooledDataSource();//设置连接池所需的驱动ds.setDriverClass("com.mysql.jdbc.Driver");//设置连接数据库的URLds.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();

这篇关于Java中JDBC相关知识的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---