首页 > 代码库 > JDBC连接MySQL
JDBC连接MySQL
java提供了一系列用于数据库编程的API--JDBC;实际上,是通过接口定义了一套访问数据库的规范,而实现这些规范的是各数据库厂商,并且将接口实现封装成.jar包;而我们程序员只需要得到数据库厂商封装的.jar包,调用JDBC API就可以连接对应的数据库.其中调用调用JDBC API这个动作是统一的.
JDBC中常见的API :
1.DriverManager类 - 驱动管理器
2.Connection类 - 连接程序与数据库
3.Statement类 - SQL语句类
4.PrepareStatement类 - 此类是Statement类的子类
5.ResultSet类 - 结果集,Result是结果的意思,Set是集合
具体操作如下:
//1、加载驱动---JDK1.8可以省略这个代码 try { Class.forName("com.mysql.jdbc.Driver");//反射代码---类加载 } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } //2、获取连接 Connection con = null; String url = "jdbc:mysql://localhost:3306/test129?useSSL=true&useUnicode=true&characterEncoding=utf8";//协议://ip地址:端口号/数据库名 String username = "root"; String password = "root"; try { con = DriverManager.getConnection(url,username,password);//连接数据库需要三个参数:url/帐号/密码 //3、构建语句对象 String sql = "";//书写sql语句 Statement state = con.createStatement();//通过连接获取语句对象 //4、语句对象执行SQL int r = state.executeUpdate(sql);//所有的DML语句都调用这个方法，该方法默认返回影响了多少行 /* * 新增数据时，有时候会需要得到自动生成的主键值. int r = state.executeUpdate(sql, Statement.RETURN_GENERATED_KEYS); ResultSet rs = state.getGeneratedKeys(); if(rs.next()){ int id = rs.getInt(1); } */ } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally{ //5、关闭连接 if(con != null){ try { con.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }以上是连接MySQL数据库以及对其中表格进行增/删/改(DML)操作,而要进行查询(DQL)操作只需对代码进行如下改动:
String sql = "select * from t_group"; Statement state = con.createStatement(); ResultSet rs = state.executeQuery(sql);//DQL语句通用这个方法 while(rs.next()){ GroupBean gb = new GroupBean(); gb.setId( rs.getInt("pk_groupid")); gb.setGroupName(rs.getString("f_groupName")); gb.setGroupAddress(rs.getString("f_groupAddress")); gb.setGroupNum(rs.getInt("f_groupNum")); allGroup.add(gb); }连接和关闭不变,变的是sql语句,查询语句返回的数据也是不同的,是以结果集ResultSet 的形式返回ResultSet 有一个.next()方法--探查是否还有下一条信息,返回boolean值,可以利用循环将查询结果装入与数据表格对应的JavaBean对象中.
从设计上数据库中表与表的关系和java中bean对象与bean的关系是相对应的.最常见的有三种关系:
| 表 | Bean | |
| 一对一 | 两张表的关系是其中一张表的外键关联另一张表,外键必须有唯一约束;也可以是两张表互相外键关联,加唯一约束 | 两个类,其中一个类has a另一个类;或者互相has |
| 一对多 | 一张主表,多张从表,所有的外键都是在多的那一方的 | 单一的一方has a多方的集合,多方has a一个单方 |
| 多对多 | 两张(或多张)主表,一张关系表所有的外键都在关系表上 | 两个类互相has a 对方类型的集合 |
具体的关系要视业务而定;
很多时候需要用用户输入内容来构建sql语句,这时就会遇到sql注入的风险,可以在此事使用PrepareStatement类代替Statement类来装sql语句,假如有一个用户表格:
String sql = "select * from t_user where f_username = ? and f_password = ?";//PrepareStatement的特点,将标准的sql模版提前书写好,将未知的部分用?号代替 PreparedStatement ps = con.prepareStatement(sql);//先将模版传入PrepareStatement构造方法产生对象 ps.setString(1, inputUsername);//传入问号的位置,和取代?的语句,在这里第一个?的位置是1,而不是0 ps.setString(2, inputPassword); ResultSet rs = ps.executeQuery();//将完整的sql语句提交 UserBean user = null; while(rs.next()){ user = new UserBean(); user.setId(rs.getInt("pk_id")); user.setUsername(rs.getString("f_username")); user.setPassword(rs.getString("f_password")); }事务 -- 由于某一业务,需要同时执行多条DML语句,一起成功,一起失败:
try { con = DriverManager.getConnection(url,username,password); //1、将连接对象的自动提交设置为假 con.setAutoCommit(false); //在此编写sql语句 con.commit();//2、手动提交 }catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); try { con.rollback();//3、回滚,如果有一条失败,就好全部回到修改前的样子 } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } } finally{ //5、关闭连接 if(con != null){ try { con.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
JDBC连接MySQL