word网站的链接怎么做,网站怎么做第二个页面,网站设计 图片,江西企业 网站建设主要内容#xff1a;JDBC连接数据库步骤。一个简单详细的查询数据的例子。封装连接数据库#xff0c;释放数据库连接方法。实现查询#xff0c;插入#xff0c;删除#xff0c;更新等十一个处理数据库信息的功能。(包括事务处理#xff0c;批量更新等)把十一个功能都放在…主要内容JDBC连接数据库步骤。一个简单详细的查询数据的例子。封装连接数据库释放数据库连接方法。实现查询插入删除更新等十一个处理数据库信息的功能。(包括事务处理批量更新等)把十一个功能都放在一起。安装下载的数据库驱动程序jar包,不同的数据库需要不同的驱动程序(这本该是第一步但是由于属于安装类所以我们放在最后)一.JDBC连接数据库(编辑)步骤(主要有六个步骤)。1.注册驱动 Class.forName(com.mysql.jdbc.Driver);显示的加载到JVM中2.获取连接(1) param1: 要连接数据库的url-----》 String urljdbc:mysql://localhost:3306/test? useUnicodetruecharacterEncodingUTF8;//防止乱码param2要连接数据库的用户名--》 String userh4;param3要连接数据库的密码----》 String pass111;Connection connDriverManager.getConnection(url,user,pass)//DriverManager下的方法getConnection(String url,String username,String password)(2)接下来我们分析下urljdbc(这是协议以jdbc开头):mysql(这是子协议数据库管理系统名称)://localhost(数据库来源地址):3306(目标端口)/test(要查询的表)?useUnicodetruecharacterEncodingUTF8;添加这个是为了防止乱码指定使用Unicode字符集 且使用UTF-8来编辑。3.创建一个Statement语句对象(主要三种方法): Statement stmtconn.createStatement();//Connection接口下的方法Statement createStatement()PreparedStatement pstmt conn.PreparedStatement() ;CallableStatement cstmt conn.prepareCall({CALL demoSp(? , ?)}) ;下面我们来分析下他们(1)Statement与PreparedStatement对象的区别后者可以动态设置查询参数(2)设置参数的方法PreparedStatement.setXXXX(parameterIndex,value)如果数据库参数类型是varchar 则用setString如果参数类型是Integer 则用setInt(3)CallableStatement.setXXXX(parameterIndex,value) //按照参数的顺序设置valueCallableStatement.setXXXX(parameterName,value) //按照参数的名字来设置value,这个名字是在定义存储过程的时候的形式参数的名字(4)CallableStatement.registerOutParameter方法用于声明一个存储过程输出类型的参数用以接收存储过程的输出值4.执行SQL语句: ResultSet rsstmt.executeQuery(Sql);除了查询语句是executeQuery();其他全部是executeUpdate();Statement接口下的方法boolean execute(String sql):执行SQL语句如果返回值是结果集则为true,否则为falseResultSet executeQuery(String sql):执行SQL语句返回值为ResultSetint executeUpdate(String sql):执行SQL语句返回值为所影响的行数5.处理结果集ResultSet对象的getXxxx方法取决于数据库中表的字段的类型例如varchar2对应方法是getString ,如果是integer对应方法是getInt/getLongWhile(rs.next()){rs.getInt(columnIndex); //通过列的序号来获取字段的值rs.getString(columnName);//通过列的名字来获取字段的值ResultSet接口下常见的方法beforeFirst();将游标移动到ResultSet中第一条记录(的前面)afterLast();将游标移动到ResultSet中最后一条记录(的后面)absolute(intcolumn):将游标移动到相对于第一行的指定行负数则为相对于最后一条记录previous():将游标上移一行next():将游标下移一行ResultSet.TYPE_SCROLL_SENSITIVE 结果集可以滚动ResultSet.CONCUR_READ_ONLY 结果集只读不能修改6.关闭资源 操作完以后要关闭jdbc来释放jdbc资源。但是顺序要和你定义对象的时候相反就像关门一样从里面先关一直往外关。如下示例if(rs !null){//1.关闭结果集try{rs.close();} catch (SQLException e){e.printStackTrace();}}if(stmt !null){//2.关闭声明的对象try{stmt.close();}catch(SQLException e){e.printStackTrace();}}if(conn !null){//3.关闭连接 (记住一定要先关闭前面的1.2.然后在关闭连接)try{conn.close();}catch(Exception e){e.printStackTrace();}}二.下面是一个简单的(详细的)查询数据的例子。1 package javacore1;//这是你建的一个包名。23 importjava.sql.CallableStatement;4 importjava.sql.Connection;5 importjava.sql.DriverManager;6 importjava.sql.PreparedStatement;7 import java.sql.ResultSet; //左边这五个是你在写程序时要导入的包名记住是要在java.sql下的包。8 importjava.sql.SQLException;9 importjava.sql.Statement;10 public class jdbc { //定义一个类11 public static void main(String[] args){ //主方法12 try{13 String drivercom.mysql.jdbc.Driver; //1.定义驱动程序名为driver内容为com.mysql.jdbc.Driver14 String urljdbc:mysql://localhost:3306/test? //2.定义urljdbc是协议mysql是子协议表示数据库系统管理名称localhost3306是你数据库来源的地址和目标端口test是我本人建的表位置所在处你以你的为标准。15 useUnicodetruecharacterEncodingUTF8; //防止乱码useUnicodetrue表示使用Unicode字符集characterEncodingUTF8表示使用UTF-8来编辑的。16 String userh4; //3.定义用户名写你想要连接到的用户。17 String pass111; //4.用户密码。18 String querySqlselect * from employees; //5.你想要查找的表名。19 Class.forName(driver); //6.注册驱动程序用java.lang包下面的class类里面的Class.froName();方法 此处的driver就是1里面定义的driver也可以 Class.forName(com.mysql.jdbc.Driver);21 Connection connDriverManager.getConnection(url,user,pass);//7.获取数据库连接,使用java.sql里面的DriverManager的getConnectin(String url , String username ,String password )来完成22 //括号里面的urluserpass便是前面定义的2,3,4步骤内容23 Statement stmtconn.createStatement(); //8.构造一个statement对象来执行sql语句主要有StatementPreparedStatementCallableStatement三种实例来实现24 //三种实现方法分别为Statement stmt con.createStatement() ;25 //PreparedStatement pstmt conn.prepareStatement(sql) ;26 //CallableStatement cstmt conn.prepareCall({CALL demoSp(? , ?)}) ;27 ResultSet rsstmt.executeQuery(querySql);//9.执行sql并返还结束 ResultSet executeQuery(String sqlString)用于返还一个结果集(ResultSet)对象。28 while(rs.next()){ //10.遍历结果集29 System.out.println(人员编号:rs.getString(employee_id)工资:rs.getString(salary)姓名:rs.getString(last_name));//使用getString()方法获取你表里的资料名30 }31 if(rs !null){//11.关闭记录集32 try{33 rs.close();34 } catch(SQLException e){35 e.printStackTrace();36 }37 }38 if(stmt !null){//12.关闭声明的对象39 try{40 stmt.close();41 }catch(SQLException e){42 e.printStackTrace();43 }44 }45 if(conn !null){//13.关闭连接 (记住一定要先关闭前面的11.12.然后在关闭连接就像关门一样先关里面的最后关最外面的)46 try{47 conn.close();48 }catch(SQLException e){49 e.printStackTrace();50 }51 }52 }catch(Exception e){53 e.printStackTrace();54 }55 }56 }三.为了更加直观我们把获取数据库连接和释放连接封装在方法里以便于后面更好的操作。1 packagejavacore1;23 importjava.sql.Connection;4 importjava.sql.DriverManager;56 public classjdbc{7 public static voidmain(String[] args){89 Connection conn getConnection(h4, 111); //获取数据库连接1011 /*,,,,此处为方法名来获取连接,例如 query(conn),,,,,*/1213 releaseConnection(conn); //释放数据库连接14 }1516 /*,,,,,,,,,,此处构建一个你想要的功能的方法,,,,,,,,,,,,*/171819 //数据库连接20 public staticConnection getConnection(String user, String pass) {2122 Connection conn null;//声明连接对象23 String driver com.mysql.jdbc.Driver;//驱动程序类名24 String url jdbc:mysql://localhost:3306/test? //数据库URL25 useUnicodetruecharacterEncodingUTF8;//防止乱码26 try{27 Class.forName(driver);//注册(加载)驱动程序28 conn DriverManager.getConnection(url, user, pass);//获取数据库连接29 } catch(Exception e) {30 e.printStackTrace();31 }32 returnconn;33 }34 //释放数据库连接35 public static voidreleaseConnection(Connection conn) {36 try{37 if (conn ! null)38 conn.close();39 } catch(Exception e) {40 e.printStackTrace();41 }42 }43 }四.实现查询、插入、删除、更新等十一个处理数据库信息的功能。1.查询数据1 packagejavacore1;2 importjava.sql.Connection;3 importjava.sql.DriverManager;4 importjava.sql.ResultSet;5 importjava.sql.SQLException;6 importjava.sql.Statement;7 public classQuery {8 public static voidmain(String[] args) {9 Connection conn getConnection(h4, 111);//获取数据库连接10 query(conn); //方法名调用数据库连接11 releaseConnection(conn);//释放数据库连接12 }13 //查询数据定义的query方法14 public static voidquery(Connection conn){15 String Sqlselect * from employees;16 try{17 Statement stmtconn.createStatement(); //也可以使用PreparedStatement来做18 ResultSet rsstmt.executeQuery(Sql);//执行sql语句并返还结束1920 while(rs.next()){//遍历结果集 向下一行21 System.out.println(人员编号:rs.getString(employee_id)工资:rs.getString(salary));22 }23 if(rs !null){24 try{25 rs.close();26 } catch(SQLException e){27 e.printStackTrace();28 }29 }30 if(stmt !null){31 try{32 stmt.close();33 }catch(SQLException e){34 e.printStackTrace();35 }36 }37 if(conn !null){38 try{39 conn.close();40 }catch(SQLException e){41 e.printStackTrace();42 }43 }44 }catch(Exception e){45 e.printStackTrace();46 }47 }48 //数据库连接49 public staticConnection getConnection(String user, String pass) {50 Connection conn null;//声明连接对象51 String driver com.mysql.jdbc.Driver;//驱动程序类名52 String url jdbc:mysql://localhost:3306/test? //数据库URL53 useUnicodetruecharacterEncodingUTF8;//防止乱码54 try{55 Class.forName(driver);//注册(加载)驱动程序56 conn DriverManager.getConnection(url, user, pass);//获取数据库连接57 } catch(Exception e) {58 e.printStackTrace();59 }60 returnconn;61 }62 //释放数据库连接63 public static voidreleaseConnection(Connection conn) {64 try{65 if (conn ! null)66 conn.close();67 } catch(Exception e) {68 e.printStackTrace();69 }70 }71 }//查询数据结果倒着显示倒序packagejavacore1;importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.ResultSet;importjava.sql.SQLException;importjava.sql.Statement;public classQuery {public static voidmain(String[] args) {Connection conn getConnection(h4, 111);//获取数据库连接query(conn); //方法名调用数据库连接releaseConnection(conn);//释放数据库连接}//查询数据定义的query方法public static voidquery(Connection conn){String Sqlselect * from employees;try{Statement stmtconn.createStatement(); //也可以使用PreparedStatement来做ResultSet rsstmt.executeQuery(Sql);//执行sql语句并返还结束rs.afterLast(); //先跳到最后一行while(rs.previous()){//遍历结果集 向上一行System.out.println(人员编号:rs.getString(employee_id)工资:rs.getString(salary));}if(rs !null){try{rs.close();}catch(SQLException e){e.printStackTrace();}}if(stmt !null){try{stmt.close();}catch(SQLException e){e.printStackTrace();}}if(conn !null){try{conn.close();}catch(SQLException e){e.printStackTrace();}}}catch(Exception e){e.printStackTrace();}}//数据库连接public staticConnection getConnection(String user, String pass) {Connection conn null;//声明连接对象String driver com.mysql.jdbc.Driver;//驱动程序类名String url jdbc:mysql://localhost:3306/test? //数据库URL useUnicodetruecharacterEncodingUTF8;//防止乱码try{Class.forName(driver);//注册(加载)驱动程序conn DriverManager.getConnection(url, user, pass);//获取数据库连接} catch(Exception e) {e.printStackTrace();}returnconn;}//释放数据库连接public static voidreleaseConnection(Connection conn) {try{if (conn ! null)conn.close();}catch(Exception e) {e.printStackTrace();}}}2.插入数据1 packagejavacore1;2 importjava.sql.Connection;3 importjava.sql.DriverManager;4 importjava.sql.SQLException;5 importjava.sql.Statement;6 public classInsert {7 public static voidmain(String[] args) {8 Connection conn getConnection(h3, 111111); //获取数据库连接9 insert(conn); //方法名调用数据库连接10 releaseConnection(conn);//释放数据库连接11 }12 //插入数据13 public static voidinsert(Connection conn) {14 try{15 String sql insert into employees(employee_id,last_name,salary,department_id,userid)16 values (100010, xiaogou, 7000,004,9); //插入数据的sql语句17 Statement stmt1 conn.createStatement(); //创建用于执行静态sql语句的Statement对象18 int count stmt1.executeUpdate(sql); //执行插入操作的sql语句并返回插入数据的个数19 System.out.println(向biao中插入了 count 条数据); //输出插入操作的处理结果20 conn.close(); //关闭数据库连接21 } catch(SQLException e) {22 e.printStackTrace();23 }24 }25 //数据库连接26 public staticConnection getConnection(String user, String pass) {27 Connection conn null;//声明连接对象28 String driver com.mysql.jdbc.Driver;//驱动程序类名29 String url jdbc:mysql://localhost:3306/test? //数据库URL30 useUnicodetruecharacterEncodingUTF8;//防止乱码31 try{32 Class.forName(driver);//注册(加载)驱动程序33 conn DriverManager.getConnection(url, user, pass);//获取数据库连接34 } catch(Exception e) {35 e.printStackTrace();36 }37 returnconn;38 }39 //释放数据库连接40 public static voidreleaseConnection(Connection conn) {41 try{42 if (conn ! null)43 conn.close();44 } catch(Exception e) {45 e.printStackTrace();46 }47 }48 }3.删除数据1 packagejavacore1;2 importjava.sql.Connection;3 importjava.sql.DriverManager;4 importjava.sql.SQLException;5 importjava.sql.Statement;6 public classDelete {7 public static voidmain(String[] args) {8 Connection conn getConnection(h3, 111111); //获取数据库连接9 delete(conn); //方法名调用数据库连接10 releaseConnection(conn);//释放数据库连接11 }12 //删除数据13 public static voiddelete(Connection conn){14 String Sql delete from employees where employee_id100009;15 try{16 Statement stmt conn.createStatement();//或者用PreparedStatement方法17 stmt.executeUpdate(Sql);//执行sql语句18 if (stmt ! null) {19 try{20 stmt.close();21 } catch(SQLException e) {22 e.printStackTrace();23 }24 }25 } catch(SQLException e) {26 e.printStackTrace();27 }2829 }30 //数据库连接31 public staticConnection getConnection(String user, String pass) {32 Connection conn null;//声明连接对象33 String driver com.mysql.jdbc.Driver;//驱动程序类名34 String url jdbc:mysql://localhost:3306/test? //数据库URL35 useUnicodetruecharacterEncodingUTF8;//防止乱码36 try{37 Class.forName(driver);//注册(加载)驱动程序38 conn DriverManager.getConnection(url, user, pass);//获取数据库连接39 } catch(Exception e) {40 e.printStackTrace();41 }42 returnconn;43 }44 //释放数据库连接45 public static voidreleaseConnection(Connection conn) {46 try{47 if (conn ! null)48 conn.close();49 } catch(Exception e) {50 e.printStackTrace();51 }52 }53 }4.更新数据1 packagejavacore1;2 importjava.sql.Connection;3 importjava.sql.DriverManager;4 importjava.sql.SQLException;5 importjava.sql.Statement;6 public classUpdate {7 public static voidmain(String[] args) {8 Connection conn getConnection(h3, 111111); //获取数据库连接9 update(conn); //方法名调用数据库连接10 releaseConnection(conn);//释放数据库连接11 }12 //更新数据13 public static voidupdate(Connection conn){14 String Sql update employees set salary8000 where employee_id100005;15 try{16 Statement stmt1 conn.createStatement();//或者用PreparedStatement方法17 stmt1.executeUpdate(Sql);//执行sql语句18 if (stmt1 ! null) {19 try{20 stmt1.close();21 } catch(SQLException e) {22 e.printStackTrace();23 }24 }25 } catch(SQLException e) {26 e.printStackTrace();27 }28 }29 //数据库连接30 public staticConnection getConnection(String user, String pass) {31 Connection conn null;//声明连接对象32 String driver com.mysql.jdbc.Driver;//驱动程序类名33 String url jdbc:mysql://localhost:3306/test? //数据库URL34 useUnicodetruecharacterEncodingUTF8;//防止乱码35 try{36 Class.forName(driver);//注册(加载)驱动程序37 conn DriverManager.getConnection(url, user, pass);//获取数据库连接38 } catch(Exception e) {39 e.printStackTrace();40 }41 returnconn;42 }43 //释放数据库连接44 public static voidreleaseConnection(Connection conn) {45 try{46 if (conn ! null)47 conn.close();48 } catch(Exception e) {49 e.printStackTrace();50 }51 }52 }5.转账(事物处理)JDBC处理事务通过关闭连接的自动提交实现的Connection.setAutoCommit(false);提交事务Connection.commit();回滚事务回滚部分Connection.rollback(Savepoint);全部回滚Connection.rollback();1 packagejavacore1;2 importjava.sql.Connection;3 importjava.sql.DriverManager;4 importjava.sql.Statement;5 public classTransCash {6 public static voidmain(String[] args) {7 Connection conn getConnection(h3, 111111);//获取数据库连接8 transCash(conn); //方法名调用数据库连接9 releaseConnection(conn);//释放数据库连接10 }11 //转账(数据调换)(原来数据为100和500实现这个功能后变成500和100其实说白了就是更新数据改数据)12 public static voidtransCash(Connection conn){13 Statement stmt null;14 try{15 conn.setAutoCommit(false);//关闭自动提交16 String sql update employees set salary500 where employee_id100001;17 stmt conn.createStatement();18 stmt.executeUpdate(sql);19 sql update employees set salary100 where employee_id100002;20 stmt.executeUpdate(sql);//执行sql语句上面的两个工资将会调换 //int i1/0;如果这样那么将不可以完成任务因为这是一个完整的事物有一点失败将全部失败21 conn.commit();//提交事务22 }catch(Exception e){23 e.printStackTrace();24 }finally{25 try{26 if(stmt ! null){ stmt.close();27 }catch(Exception e){28 e.printStackTrace();29 }30 }31 }32 //数据库连接33 public staticConnection getConnection(String user, String pass) {34 Connection conn null;//声明连接对象35 String driver com.mysql.jdbc.Driver;//驱动程序类名36 String url jdbc:mysql://localhost:3306/test? //数据库URL37 useUnicodetruecharacterEncodingUTF8;//防止乱码38 try{39 Class.forName(driver);//注册(加载)驱动程序40 conn DriverManager.getConnection(url, user, pass);//获取数据库连接41 } catch(Exception e) {42 e.printStackTrace();43 }44 returnconn;45 }46 //释放数据库连接47 public static voidreleaseConnection(Connection conn) {48 try{49 if (conn ! null)50 conn.close();51 } catch(Exception e) {52 e.printStackTrace();53 }54 }55 }6.查找存储过程无参数的1 packagejavacore1;2 importjava.sql.CallableStatement;3 importjava.sql.Connection;4 importjava.sql.DriverManager;5 importjava.sql.SQLException;6 public classExecProc {7 public static voidmain(String[] args) {8 Connection conn getConnection(h3, 111111); //获取数据库连接9 execProc(conn);//方法名调用数据库连接10 releaseConnection(conn);//释放数据库连接11 }12 //调用无参存储过程13 public static voidexecProc(Connection conn){14 String sql {call raisesalary};15 try{16 CallableStatement cstmt conn.prepareCall(sql);17 cstmt.executeUpdate();18 } catch(SQLException e) {19 e.printStackTrace();20 }21 }22 //数据库连接23 public staticConnection getConnection(String user, String pass) {24 Connection conn null;//声明连接对象25 String driver com.mysql.jdbc.Driver;//驱动程序类名26 String url jdbc:mysql://localhost:3306/test? //数据库URL27 useUnicodetruecharacterEncodingUTF8;//防止乱码28 try{29 Class.forName(driver);//注册(加载)驱动程序30 conn DriverManager.getConnection(url, user, pass);//获取数据库连接31 } catch(Exception e) {32 e.printStackTrace();33 }34 returnconn;35 }36 //释放数据库连接37 public static voidreleaseConnection(Connection conn) {38 try{39 if (conn ! null)40 conn.close();41 } catch(Exception e) {42 e.printStackTrace();43 }44 }45 }7.查找存储过程有参数的1 packagejavacore1;2 importjava.sql.CallableStatement;3 importjava.sql.Connection;4 importjava.sql.DriverManager;5 importjava.sql.Types;6 public classGetMulti {7 public static voidmain(String[] args) {8 Connection conn getConnection(h3, 111111); //获取数据库连接9 int cnt getMulti(conn); //查找存储过程10 System.out.println(人员编号 cnt);11 releaseConnection(conn);//释放数据库连接12 }13 //查找存储过程有参14 public static intgetMulti(Connection conn) {15 int dept_id 100001;16 int cnt 0;17 String sql {call calc_emp_count(?,?)};18 try{19 CallableStatement cstmt conn.prepareCall(sql);//初始化Statement对象20 cstmt.setInt(1, dept_id);//CallableStatement.setxxx(参数值)或者(数字,值),而PreparedStatement.setxxx(数字,值)只能这样21 cstmt.setInt(2, cnt); //22 cstmt.registerOutParameter(2, Types.INTEGER);//声明输出参数23 cstmt.executeUpdate();//执行sql语句24 cnt cstmt.getInt(2);//获取结果25 if (cstmt ! null) {26 cstmt.close();//释放Statement对象27 }28 } catch(Exception e) {29 e.printStackTrace();30 }31 returncnt;32 }33 //数据库连接34 public staticConnection getConnection(String user, String pass) {35 Connection conn null;//声明连接对象36 String driver com.mysql.jdbc.Driver;//驱动程序类名37 String url jdbc:mysql://localhost:3306/test? //数据库URL38 useUnicodetruecharacterEncodingUTF8;//防止乱码39 try{40 Class.forName(driver);//注册(加载)驱动程序41 conn DriverManager.getConnection(url, user, pass);//获取数据库连接42 } catch(Exception e) {43 e.printStackTrace();44 }45 returnconn;46 }47 //释放数据库连接48 public static voidreleaseConnection(Connection conn) {49 try{50 if (conn ! null)51 conn.close();52 } catch(Exception e) {53 e.printStackTrace();54 }55 }56 }8.普通处理1 packagejavacore1;2 importjava.sql.Connection;3 importjava.sql.Date;4 importjava.sql.DriverManager;5 importjava.sql.PreparedStatement;6 importjava.sql.SQLException;7 public classPlanInsert {8 public static voidmain(String[] args) {9 Connection conn getConnection(h3, 111111); //获取数据库连接10 planInsert(conn); //方法名调用数据库连接11 releaseConnection(conn);//释放数据库连接12 }13 //普通处理14 public static voidplanInsert(Connection conn) {15 try{16 String sql insert into test_user1(userid,username,loadingtime)17 values (?,?,?); //插入数据的sql语句18 PreparedStatement pstmtconn.prepareStatement(sql);19 long startTimeSystem.currentTimeMillis();20 for(int i0;i1000;i){21 pstmt.setLong(1, i);22 pstmt.setString(2, useri);23 pstmt.setDate(3, newDate(System.currentTimeMillis()));24 pstmt.executeUpdate();25 }26 System.out.println(总共耗时(System.currentTimeMillis() -startTime));27 pstmt.close(); //关闭数据库连接28 } catch(SQLException e) {29 e.printStackTrace();30 }31 }32 //数据库连接33 public staticConnection getConnection(String user, String pass) {34 Connection conn null;//声明连接对象35 String driver com.mysql.jdbc.Driver;//驱动程序类名36 String url jdbc:mysql://localhost:3306/test? //数据库URL37 useUnicodetruecharacterEncodingUTF8;//防止乱码38 try{39 Class.forName(driver);//注册(加载)驱动程序40 conn DriverManager.getConnection(url, user, pass);//获取数据库连接41 } catch(Exception e) {42 e.printStackTrace();43 }44 returnconn;45 }46 //释放数据库连接47 public static voidreleaseConnection(Connection conn) {48 try{49 if (conn ! null)50 conn.close();51 } catch(Exception e) {52 e.printStackTrace();53 }54 }55 }9.批量处理获得原来JDBC事务的模式boolean currentTransactionModle con.getAutoCommit();设置成事务模式(关闭自动提交)con.setAutoCommit(false);Statement stm con.createStatement();三个异构的sql语句String sql1 delete from user where id 8;String sql2 update user set namejava where id 7;String sql3 insert into user(name,password) values(jdbc,jdbc);添加到Statement的批量处理缓冲区中stm.addBatch(sql1);stm.addBatch(sql2);stm.addBatch(sql3);执行批量更新stm.executeBatch();提交本次批量更新的事务con.commit();回复原来的事务模式con.setAutoCommit(currentTransactionModle);1 packagejavacore1;2 importjava.sql.Connection;3 importjava.sql.Date;4 importjava.sql.DriverManager;5 importjava.sql.PreparedStatement;6 importjava.sql.SQLException;7 public classBatchInsert {8 public static voidmain(String[] args) {9 Connection conn getConnection(h3, 111111); //获取数据库连接10 batchInsert(conn); //方法名调用数据库连接11 releaseConnection(conn);//释放数据库连接12 }13 //批量插入的速度要比普通处理的速度快14 public static voidbatchInsert(Connection conn) {15 try{16 String sql insert into test_user1(userid,username,loadingtime)17 values (?,?,?); //插入数据的sql语句18 PreparedStatement pstmtconn.prepareStatement(sql);19 long startTimeSystem.currentTimeMillis();20 for(int i0;i1000;i){21 pstmt.setLong(1, i);22 pstmt.setString(2, useri);23 pstmt.setDate(3, newDate(System.currentTimeMillis()));24 pstmt.addBatch();//添加到批量处理25 }26 int[] resultpstmt.executeBatch();27 System.out.println(总共耗时(System.currentTimeMillis() -startTime));28 pstmt.close(); //关闭数据库连接29 } catch(SQLException e) {30 e.printStackTrace();31 }32 }33 //数据库连接34 public staticConnection getConnection(String user, String pass) {35 Connection conn null;//声明连接对象36 String driver com.mysql.jdbc.Driver;//驱动程序类名37 String url jdbc:mysql://localhost:3306/test? //数据库URL38 useUnicodetruecharacterEncodingUTF8;//防止乱码39 try{40 Class.forName(driver);//注册(加载)驱动程序41 conn DriverManager.getConnection(url, user, pass);//获取数据库连接42 } catch(Exception e) {43 e.printStackTrace();44 }45 returnconn;46 }47 //释放数据库连接48 public static voidreleaseConnection(Connection conn) {49 try{50 if (conn ! null)51 conn.close();52 } catch(Exception e) {53 e.printStackTrace();54 }55 }56 }10.分页显示1 packagejavacore1;2 importjava.sql.Connection;3 importjava.sql.DriverManager;4 importjava.sql.PreparedStatement;5 importjava.sql.ResultSet;6 importjava.sql.SQLException;7 public classPaging {8 public static voidmain(String[] args) {9 Connection conn getConnection(h3, 111111); //获取数据库连接10 paging(conn,1,3);//方法名调用数据库连接,且定义显示第几行到第几行11 releaseConnection(conn);//释放数据库连接12 }13 //分页查询14 public static void paging(Connection conn,int startIndex,inttotal){15 try{16 String sqlselect * from employees limit ?,?;17 PreparedStatement pstmtconn.prepareStatement(sql);18 pstmt.setInt(1, startIndex);19 pstmt.setInt(2, total);20 ResultSet rspstmt.executeQuery();21 while(rs.next()){22 System.out.print(工号rs.getInt(1));23 System.out.println(部门编号rs.getInt(department_id));24 }rs.close();25 pstmt.close();26 }catch(SQLException e){27 e.printStackTrace();28 }29 }30 //数据库连接31 public staticConnection getConnection(String user, String pass) {32 Connection conn null;//声明连接对象33 String driver com.mysql.jdbc.Driver;//驱动程序类名34 String url jdbc:mysql://localhost:3306/test? //数据库URL35 useUnicodetruecharacterEncodingUTF8;//防止乱码36 try{37 Class.forName(driver);//注册(加载)驱动程序38 conn DriverManager.getConnection(url, user, pass);//获取数据库连接39 } catch(Exception e) {40 e.printStackTrace();41 }42 returnconn;43 }44 //释放数据库连接45 public static voidreleaseConnection(Connection conn) {46 try{47 if (conn ! null)48 conn.close();49 } catch(Exception e) {50 e.printStackTrace();51 }52 }53 }11.结果集可以滚动1 packagejavacore1;2 importjava.sql.Connection;3 importjava.sql.DriverManager;4 importjava.sql.PreparedStatement;5 importjava.sql.ResultSet;6 importjava.sql.SQLException;7 public classScrpllResult {8 public static voidmain(String[] args) {9 Connection conn getConnection(h3, 111111); //获取数据库连接10 scrpllResult(conn);//方法名调用数据库连接11 releaseConnection(conn);//释放数据库连接12 }13 //结果集滚动显示14 public static voidscrpllResult(Connection conn){15 try{16 String sqlselect * from employees; //结果集可以滚动//并发性,结果集只读不可以修改17 PreparedStatement pstmtconn.prepareStatement(sql, ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);18 ResultSet rspstmt.executeQuery();19 while(rs.next()){ //向下一行遍历20 System.out.print(工号rs.getLong(1));21 System.out.println(名字rs.getString(last_name));22 }while(rs.previous()){//向上一行遍历23 System.out.print(工号rs.getLong(1));24 System.out.println(工资rs.getInt(salary));25 }26 rs.absolute(6);//表示直接跳到第几行27 if(rs.next()){28 System.out.print(工号rs.getLong(1));29 System.out.println(..........部门编号rs.getString(department_id));30 }31 rs.close();32 pstmt.close();33 }catch(SQLException e){34 e.printStackTrace();35 }36 }37 //数据库连接38 public staticConnection getConnection(String user, String pass) {39 Connection conn null;//声明连接对象40 String driver com.mysql.jdbc.Driver;//驱动程序类名41 String url jdbc:mysql://localhost:3306/test? //数据库URL42 useUnicodetruecharacterEncodingUTF8;//防止乱码43 try{44 Class.forName(driver);//注册(加载)驱动程序45 conn DriverManager.getConnection(url, user, pass);//获取数据库连接46 } catch(Exception e) {47 e.printStackTrace();48 }49 returnconn;50 }51 //释放数据库连接52 public static voidreleaseConnection(Connection conn) {53 try{54 if (conn ! null)55 conn.close();56 } catch(Exception e) {57 e.printStackTrace();58 }59 }60 }五.把上面十一个放在一起当然最方便省事。(需要用谁只需把前面的注释打开便行)1 packagejavacore1;2 importjava.sql.CallableStatement;3 importjava.sql.Connection;4 importjava.sql.Date;5 importjava.sql.DriverManager;6 importjava.sql.PreparedStatement;7 importjava.sql.ResultSet;8 importjava.sql.SQLException;9 importjava.sql.Statement;10 importjava.sql.Types;11 public classjdbcMySql {12 public static voidmain(String[] args) {13 Connection conn getConnection(h3, 111111); //获取数据库连接14 //query(conn);//1.查询数据15 //insert(conn);//2.插入数据16 //delete(conn);//3.删除数据17 //update(conn);//4.更新数据18 //transCash(conn);//5.转账19 //execProc(conn);//6.查找存储过程无参数的20 //int cnt getMulti(conn);//7.查找存储过程有参数的21 //System.out.println(人员编号 cnt);//查找存储过程有参数的22 //planInsert(conn);//8.普通处理23 //batchInsert(conn);//9.批量处理24 //paging(conn,1,3);//10.分页显示25 //scrpllResult(conn);//11.结果集可以滚动26 releaseConnection(conn);//释放数据库连接27 }28 //1.查询数据定义的query方法29 public static voidquery(Connection conn){30 String Sqlselect * from employees;31 try{32 Statement stmtconn.createStatement(); //也可以使用PreparedStatement来做33 ResultSet rsstmt.executeQuery(Sql);//执行sql语句并返还结束3435 while(rs.next()){//遍历结果集36 System.out.println(人员编号:rs.getString(employee_id)工资:rs.getString(salary));37 }38 if(rs !null){39 try{40 rs.close();41 } catch(SQLException e){42 e.printStackTrace();43 }44 }45 if(stmt !null){46 try{47 stmt.close();48 }catch(SQLException e){49 e.printStackTrace();50 }51 }52 if(conn !null){53 try{54 conn.close();55 }catch(SQLException e){56 e.printStackTrace();57 }58 }59 }catch(Exception e){60 e.printStackTrace();61 }62 }63 //2.插入数据64 public static voidinsert(Connection conn) {65 try{66 String sql insert into employees(employee_id,last_name,salary,department_id,userid)67 values (100010, xiaogou, 7000,004,9); //插入数据的sql语句68 Statement stmt1 conn.createStatement(); //创建用于执行静态sql语句的Statement对象69 int count stmt1.executeUpdate(sql); //执行插入操作的sql语句并返回插入数据的个数70 System.out.println(向biao中插入了 count 条数据); //输出插入操作的处理结果71 conn.close(); //关闭数据库连接72 } catch(SQLException e) {73 e.printStackTrace();74 }75 }76 //3.删除数据77 public static voiddelete(Connection conn){78 String Sql delete from employees where employee_id100009;79 try{80 Statement stmt conn.createStatement();//或者用PreparedStatement方法81 stmt.executeUpdate(Sql);//执行sql语句82 if (stmt ! null) {83 try{84 stmt.close();85 } catch(SQLException e) {86 e.printStackTrace();87 }88 }89 } catch(SQLException e) {90 e.printStackTrace();91 }9293 }94 //4.更新数据95 public static voidupdate(Connection conn){96 String Sql update employees set salary8000 where employee_id100005;97 try{98 Statement stmt1 conn.createStatement();//或者用PreparedStatement方法99 stmt1.executeUpdate(Sql);//执行sql语句100 if (stmt1 ! null) {101 try{102 stmt1.close();103 } catch(SQLException e) {104 e.printStackTrace();105 }106 }107 } catch(SQLException e) {108 e.printStackTrace();109 }110 }111 //5.转账(数据调换)(原来数据为100和500实现这个功能后变成500和100其实说白了就是更新数据改数据)112 public static voidtransCash(Connection conn){113 Statement stmt null;114 try{115 conn.setAutoCommit(false);//关闭自动提交116 String sql update employees set salary500 where employee_id100001;117 stmt conn.createStatement();118 stmt.executeUpdate(sql);119 sql update employees set salary100 where employee_id100002;120 stmt.executeUpdate(sql);//执行sql语句上面的两个工资将会调换121 conn.commit();//提交事务122 }catch(Exception e){123 e.printStackTrace();124 }finally{125 try{126 if(stmt ! null)stmt.close();127 }catch(Exception e){128 e.printStackTrace();129 }130 }131 }132 //6.调用无参存储过程133 public static voidexecProc(Connection conn){134 String sql {call raisesalary};135 try{136 CallableStatement cstmt conn.prepareCall(sql);137 cstmt.executeUpdate();138 } catch(SQLException e) {139 e.printStackTrace();140 }141 }142 //7.查找存储过程有参143 public static intgetMulti(Connection conn) {144 int dept_id 100001;145 int cnt 0;146 String sql {call calc_emp_count(?,?)};147 try{148 CallableStatement cstmt conn.prepareCall(sql);//初始化Statement对象149 cstmt.setInt(1, dept_id);//CallableStatement.setxxx(参数值)或者(数字,值),而PreparedStatement.setxxx(数字,值)只能这样150 cstmt.setInt(2, cnt); //151 cstmt.registerOutParameter(2, Types.INTEGER);//声明输出参数152 cstmt.executeUpdate();//执行sql语句153 cnt cstmt.getInt(2);//获取结果154 if (cstmt ! null) {155 cstmt.close();//释放Statement对象156 }157 } catch(Exception e) {158 e.printStackTrace();159 }160 returncnt;161 }162 //8.普通处理163 public static voidplanInsert(Connection conn) {164 try{165 String sql insert into test_user1(userid,username,loadingtime)166 values (?,?,?); //插入数据的sql语句167 PreparedStatement pstmtconn.prepareStatement(sql);168 long startTimeSystem.currentTimeMillis();169 for(int i0;i1000;i){170 pstmt.setLong(1, i);171 pstmt.setString(2, useri);172 pstmt.setDate(3, newDate(System.currentTimeMillis()));173 pstmt.executeUpdate();174 }175 System.out.println(总共耗时(System.currentTimeMillis() -startTime));176 pstmt.close(); //关闭数据库连接177 } catch(SQLException e) {178 e.printStackTrace();179 }180 }181 //9.批量插入的速度要比普通处理的速度快182 public static voidbatchInsert(Connection conn) {183 try{184 String sql insert into test_user1(userid,username,loadingtime)185 values (?,?,?); //插入数据的sql语句186 PreparedStatement pstmtconn.prepareStatement(sql);187 long startTimeSystem.currentTimeMillis();188 for(int i0;i1000;i){189 pstmt.setLong(1, i);190 pstmt.setString(2, useri);191 pstmt.setDate(3, newDate(System.currentTimeMillis()));192 pstmt.addBatch();//添加到批量处理193 }194 int[] resultpstmt.executeBatch();195 System.out.println(总共耗时(System.currentTimeMillis() -startTime));196 pstmt.close(); //关闭数据库连接197 } catch(SQLException e) {198 e.printStackTrace();199 }200 }201 //10.分页查询202 public static void paging(Connection conn,int startIndex,inttotal){203 try{204 String sqlselect * from employees limit ?,?;205 PreparedStatement pstmtconn.prepareStatement(sql);206 pstmt.setInt(1, startIndex);207 pstmt.setInt(2, total);208 ResultSet rspstmt.executeQuery();209 while(rs.next()){210 System.out.print(工号rs.getInt(1));211 System.out.println(部门编号rs.getInt(department_id));212 }rs.close();213 pstmt.close();214 }catch(SQLException e){215 e.printStackTrace();216 }217 }218 //11.结果集滚动显示219 public static voidscrpllResult(Connection conn){220 try{221 String sqlselect * from employees; //结果集可以滚动//并发性,结果集只读不可以修改222 PreparedStatement pstmtconn.prepareStatement(sql, ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);223 ResultSet rspstmt.executeQuery();224 while(rs.next()){ //向下一行遍历225 System.out.print(工号rs.getLong(1));226 System.out.println(名字rs.getString(last_name));227 }while(rs.previous()){//向上一行遍历228 System.out.print(工号rs.getLong(1));229 System.out.println(工资rs.getInt(salary));230 }231 rs.absolute(6);//表示直接跳到第几行232 if(rs.next()){233 System.out.print(工号rs.getLong(1));234 System.out.println(..........部门编号rs.getString(department_id));235 }236 rs.close();237 pstmt.close();238 }catch(SQLException e){239 e.printStackTrace();240 }241 }242 //数据库连接243 public staticConnection getConnection(String user, String pass) {244 Connection conn null;//声明连接对象245 String driver com.mysql.jdbc.Driver;//驱动程序类名246 String url jdbc:mysql://localhost:3306/test? //数据库URL247 useUnicodetruecharacterEncodingUTF8;//防止乱码248 try{249 Class.forName(driver);//注册(加载)驱动程序250 conn DriverManager.getConnection(url, user, pass);//获取数据库连接251 } catch(Exception e) {252 e.printStackTrace();253 }254 returnconn;255 }256 //释放数据库连接257 public static voidreleaseConnection(Connection conn) {258 try{259 if (conn ! null)260 conn.close();261 } catch(Exception e) {262 e.printStackTrace();263 }264 }265 }六.安装下载的数据库驱动程序jar包,不同的数据库需要不同的驱动程序(但是安装方法都是一样的)在使用JDBC编程时需要连接数据库导入JAR包是必须的导入其它的jar包方法同样如此导入的方法是打开eclipse1.右击要导入jar包的项目点properties2.左边选择java build path,右边选择libraries3.选择add External jars4.选择jar包的按照路径下的确定后就行了。Java连接MySQL的最新驱动包下载地址1.鼠标放在你建的根目录上面。右击然后选择最下面的properties。2.然后左边选择java build path,右边选择libraries 在选择右边的add External jars 选择jar包的路径点击确定就可以了3.装好后图如下出现你要添加的包。
