本文主要是介绍Java中JDBC相关知识,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
1. JDBC编程步骤
- 加载数据库驱动
- 通过DriverManager获得数据库连接
- 通过Connection对象创建Statement对象
- 使用Statement执行SQL语句
- 操作结果集
- 回收数据库资源
//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相关知识的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!