java实训第一天

在今天学习了PowerDesigner来绘画数据库的E-R图

而且使用了jdbc的方式来连接数据库并且对数据库中的数据进行操作

1.首先我们需要将jar导入我们项目中的lib包中

jar包的位置

其中我们需要根据我们MySQL的版本来导入我们所对应的jar包

2.创建JDBC的驱动类

查看jdk提供的api 来完成具体操作

       2.1通过调用api来读取到我们的mysql的jar包

                  通过反射来读取mysql.jar

                   //加载jar

                   Class.forName("com.mysql.jdbc.Driver")

       2.2通过驱动管理器的类来管理驱动建立连接 

                  Connection con =DriverManager.getConnection("jdbc:mysql://localhost:3306/zyfund", "root", "123456");

       2.3通过连接对象来操作（获取发送sql的对象 PreparedStatement）

                   PreparedStatement pst =con.prepareStatement("select * from t_user_manage");

       2.4 通过发送sql的对象来操作sql （查询返回的ResultSet 调用的是executeQuery()  增删改返回的是int 调用的executeUpdate() 方法）

       2.5关闭资源

在目录下我们创建我们JDBC的驱动类

package com.seehope.utils;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;/*** * jdbc的帮助类用户获取连接关闭资源 * @author admin * */public class JDBCUtils { //定义驱动包的常量 private static final String DRIVERClASS="com.mysql.jdbc.Driver"; //定义连接数据库的url常量 private static final String URL="jdbc:mysql:///test"; //定义连接数据库的用户名的常量 private static final String USERNAME="root"; //定义连接数据库的密码的常量 private static final String PASSWORD=""; static { try { Class.forName(DRIVERClASS); } catch (Exception e) { } } /*** * 获取数据库连接的方法 * @return */ public static Connection getConnection() { Connection con=null; try { con=DriverManager.getConnection(URL, USERNAME, PASSWORD); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return con; } /*** * 关闭数据库资源的方法 * @param con * @param pst * @param rs */ public static void close(Connection con,PreparedStatement pst,ResultSet rs) { try { if(rs!=null) rs.close(); if(pst!=null) pst.close(); if(con!=null) con.close(); } catch (Exception e) { // TODO: handle exception } }} 

3.对表进行增删改查

package com.seehope.test;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import org.junit.Test;/*** * 通过jdbc操作数据库 * @author admin * */public class JdbcTest { /*** * 查询用户 * @throws Exception */ @Test public void findUser() throws Exception{ //加载jar Class.forName("com.mysql.jdbc.Driver"); //通过驱动管理器建立连接获取连接对象 Connection con =DriverManager.getConnection("jdbc:mysql://localhost:3306/oneday", "root", ""); //获取操作数据库的对象 PreparedStatement pst =con.prepareStatement("select * from user"); //发送sql ResultSet rs= pst.executeQuery(); //遍历结果集 while(rs.next()) { System.out.println("id:"+rs.getInt("id")+"name:"+rs.getString("name")+"password:"+rs.getString("password")); } //关闭资源 if(rs!=null) rs.close(); if(pst!=null) pst.close(); if(con!=null) con.close(); } /** * 增加用户 * @throws Exception */ @Test public void addUser() throws Exception{ //加载jar Class.forName("com.mysql.jdbc.Driver"); //通过驱动管理器的类来获取连接对象 Connection con =DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", ""); //获取执行sql的对象 PreparedStatement pst =con.prepareStatement("insert into student(id,name,password) values(?,?,?)"); //解析占位符 //pst.setInt(0, 1); pst.setInt(1, 5); pst.setString(2, "5"); pst.setString(3, "5"); //执行sql int count =pst.executeUpdate(); if(count>0) System.out.println("插入成功"); else System.out.println("插入失败"); //关闭资源 if(pst!=null) pst.close(); if(con!=null) con.close(); } /*** * 修改用户 * @throws Exception */ @Test public void updateUser() throws Exception{ //加载jar Class.forName("com.mysql.jdbc.Driver"); //通过驱动管理器类获取数据库连接 Connection con =DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", ""); //通过连接对象获取操作数据库对象 PreparedStatement pst =con.prepareStatement("update student set name=?,password=? where id=?"); //解析占位符 pst.setString(1, "1"); pst.setString(2, "1"); pst.setInt(3, 1); //执行sql语句 int count =pst.executeUpdate(); if(count>0) System.out.println("修改成功"); else System.out.println("修改失败"); //关闭资源 if(pst!=null) pst.close(); if(con!=null) con.close(); } /*** * 删除用户 */ @Test public void deleteUser() throws Exception{ //加载jar Class.forName("com.mysql.jdbc.Driver"); //通过驱动管理器类获取数据库连接 Connection con =DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", ""); //通过连接对象获取操作数据库的对象 PreparedStatement pst =con.prepareStatement("delete from student where id=?"); //解析占位符 pst.setInt(1, 4); //执行sql int count =pst.executeUpdate(); if(count>0) System.out.println("删除成功"); else System.out.println("删除失败"); //关闭资源 if(pst!=null) pst.close(); if(con!=null) con.close(); }}