SUN公司为了简化、统一对数据库的操做,定义了一套java操做数据库的规范,称之为JDBC,JDBC不能直接操做数据库,JDBC经过接口加载数据库的驱动,而后操做数据库。JDBC:Java Data Base Connectivity,它主要由接口组成。组成JDBC的2个包为java.sql和javax.sql。开发JDBC应用须要这2个包的支持外,还须要导入相应JDBC的数据库实现(即数据库驱动)。java
编程从user表中读取数据,并打印在控制台窗口中。
mysql
create database test Character set utf8 collate utf8_general_ci; use test create table user ( id int primary Key, name varchar(20), password varchar(20), email varchar(20), birthday Date ); insert into user(id,name,password,email,birthday) values(1,'zw','123','zw@sina.com','1990-09-19'); insert into user(id,name,password,email,birthday) values(2,'ls','123','ls@sina.com','1991-04-19'); insert into user(id,name,password,email,birthday) values(3,'ww','123','ww@sina.com','1992-06-19');
新建一个java工程,并导入数据库驱动 mysql-connector-java-5.1.20-bin.jar。sql
public class Demo1 { public static void main(String[] args) throws Exception { String url = "jdbc:mysql://localhost:3306/day14"; String username = "root"; String password = "root"; try{ //1.加载驱动 //DriverManager.registerDriver(new Driver()); Class.forName("com.mysql.jdbc.Driver"); //2.获取数据库的链接 Connection conn = DriverManager.getConnection(url, username, password); //3.得到用于向数据库发送sql语句的statement对象 Statement st = conn.createStatement(); //4.向数据库发sql,并获取表明结果集的resultset String sql = "select id,name,password,email,birthday from user"; ResultSet rs = st.executeQuery(sql); //取出结果集的数据 while(rs.next()){ int id = (Integer) rs.getObject("id"); String name = (String)rs.getObject("name"); String pd = (String)rs.getObject("password"); String email = (String)rs.getObject("email"); Date birthday = (Date)rs.getObject("birthday"); System.out.println(id+","+name+","+pd+","+email+","+birthday); } } //关闭链接 finally{ if(rs != null){ try{ rs.close(); }catch(Exception e) { e.printStackTrace(); } rs = null; } if(st != null){ try{ st.close(); }catch(Exception e) { e.printStackTrace(); } st = null; } if(conn != null){ try{ conn.close(); }catch(Exception e) { e.printStackTrace(); } conn = null; } } } }JDBC程序中的DriverManager用于加载驱动,并建立与数据库的链接,这个类的经常使用方法有:
DriverManager.registerDriver(new Driver()); DriverManager.getConnection(URL, user, password);注意:在实际开发中不推荐采用registerDriver方法注册驱动,缘由有二:
JDBC程序中的Connection对象用于表明数据库的链接,Connection是数据库编程中最重要的一个对象,客户端与数据库全部交互都是经过Connection对象完成的。这个对象经常使用的方法有:数据库
createStatement(); //建立向数据库发送sql的statement对象 prepareStatement(sql); //建立向数据库发送预编译sql的prepareStatement对象。这个更经常使用 prepareCall(sql); //建立执行存储过程当中的callableStatement对象 setAutoCommit(boolean autoCommit); //设置事物是否自动提交 commit(); //在连接上提交事物 rollback(); //在此连接上回滚事物JDBC程序中的Statement对象用于向数据库发送sql语句,Statement对象经常使用方法有:
executeQuery(String sql); //用于向数据库发送查询语句 executeUpdate(String sql); //用于向数据库发送insert,update或delete语句 execute(String sql); //用于向数据库发送任意sql语句 addBatch(String sql); //把多条sql语句放到一个批处理中 executeBath(); //向数据库发送一批sql语句执行JDBC程序中的ResultSet对象用于表明sql语句的执行结果。ResultSet封装执行结果时,采用的相似于表格的方式。ResultSet对象维护了一个指向表格数据行的游标,初始的时候,游标在第一行以前,调用该对象的next()方法,可使游标指向具体的数据行,进行调用方法获取该行的数据。因为ResultSet用于封装执行结果,因此该对象提供的都是用于获取数据的get方法:
//获取任意类型的数据 getObject(int index); //index表示列号 getObject(String columnName); //columnName表示列名,建议用这种方法,更好维护 //获取指定类型的数据(int,String,Date等) getString(int index); getString(String columnName);ResultSet除了提供get方法之外,还提供了对结果集进行滚动的方法:
next(); //移动到下一行 previous(); //移动到前一行 absolute(int row); //移动到指定行 beforeFirst(); //移动到resultSet的最前面 afterLast(); //移动到resultSet的最后面为了确保资源释放代码能运行,资源释放代码必定要写在finally语句中。
JDBC技术主要是同数据库打交道,那么免不了增删改查,由上面的代码能够看出,在对数据库进行操做以前须要先创建链接,在操做以后都须要释放资源,因此咱们能够把这两部份内容抽取出来,写到JDBCUtils类中来实现:编程
public class JDBCUtils { private static String driver = null; private static String url = null; private static String username = null; private static String password = null; //加载驱动 static{ try { //db.properties是一个配置文件,里面有链接数据库所须要的信息 InputStream in = JDBCUtils.class.getClassLoader().getResourceAsStream("db.properties"); Properties prop = new Properties(); prop.load(in);//加载配置文件 driver = prop.getProperty("driver"); url = prop.getProperty("url"); username = prop.getProperty("username"); password = prop.getProperty("password"); Class.forName(driver);//加载驱动 } catch (Exception e) { throw new ExceptionInInitializerError(e); } } public static Connection getConnection() throws SQLException{ return DriverManager.getConnection(url, username, password);//得到connection } public static void release(Connection conn, Statement st, ResultSet rs){ //释放资源 if(rs != null){ try{ rs.close(); }catch(Exception e) { e.printStackTrace(); } rs = null; } if(st != null){ try{ st.close(); }catch(Exception e) { e.printStackTrace(); } st = null; } if(conn != null){ try{ conn.close(); }catch(Exception e) { e.printStackTrace(); } conn = null; } } }db.properties文件:
driver=com.mysql.jdbc.Driver url=jdbc:mysql://localhost:3306/day14 username=root password=root这样咱们就完成了数据库的链接和资源的释放工具类。下面咱们开始编写对数据库的增删改查:
//使用JDBC对数据库的增删改查 public class Demo2 { private Connection conn = null; private Statement st = null; private ResultSet rs = null; @Test public void insert(){ try { conn = JDBCUtils.getConnection(); st = conn.createStatement(); String sql = "insert into user(id,name,password,email,birthday) values(3,'ww','123','ww@sina.com','1982-06-14');"; int num = st.executeUpdate(sql);//返回的是该sql语句会影响数据库的几行 if(num > 0){ System.out.println(num); System.out.println("插入成功"); } } catch (Exception e) { e.printStackTrace(); }finally { JDBCUtils.release(conn, st, rs); } } @Test public void delete(){ try { conn = JDBCUtils.getConnection(); st = conn.createStatement(); String sql = "delete from user where password='123'"; int num = st.executeUpdate(sql); if(num > 0){ System.out.println(num); System.out.println("删除成功"); } } catch (Exception e) { e.printStackTrace(); }finally { JDBCUtils.release(conn, st, rs); } } @Test public void update(){ try { conn = JDBCUtils.getConnection(); st = conn.createStatement(); String sql = "update user set password='456' where name='ww'"; int num = st.executeUpdate(sql); if(num > 0) { System.out.println(num); System.out.println("修改为功"); } } catch (Exception e) { e.printStackTrace(); }finally { JDBCUtils.release(conn, st, rs); } } @Test public void find(){ try { conn = JDBCUtils.getConnection(); st = conn.createStatement(); String sql = "select id,name,password,email,birthday from user"; rs = st.executeQuery(sql); while(rs.next()){ int id = (Integer)rs.getObject("id"); String name = (String)rs.getObject("name"); String password = (String)rs.getObject("password"); String email = (String)rs.getObject("email"); Date birthday = (Date)rs.getObject("birthday"); System.out.println(id+","+name+","+password+","+email+","+birthday); } } catch (Exception e) { e.printStackTrace(); }finally { JDBCUtils.release(conn, st, rs); } } }JDBC基本知识点就介绍到这,后面再介绍一些高级点的应用,若有错误之处,欢迎留言指正~
_____________________________________________________________________________________________________________________________________________________api
-----乐于分享,共同进步!
工具