当前位置：文档之家 › 第12章 Java 数据库操作

第12章 Java 数据库操作

  • 格式：doc
  • 大小：46.00 KB
  • 文档页数：6

第12章 Java 数据库操作 实验1 JDBC-ODBC桥接器 2．模板代码 Excel.java import java.sql.*; public class Excel { public static void main(String args[]) { Connection con; Statement sql; ResultSet rs; try { Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); } catch(ClassNotFoundException e){ System.out.println(""+e); } try{ con=DriverManager.getConnection("jdbc:odbc:star","",""); sql=con.createStatement(); rs=sql.executeQuery("SELECT * FROM message"); while(rs.next()){ String number=rs.getString(1); String name=rs.getString(2); String unit=rs.getString(3); double price=rs.getInt(4); System.out.println(number+","+name+","+unit+","+price); } con.close(); } catch(SQLException e){ System.out.println(e); } } }

实验2 查询、更新和插入操作

2．模板代码 LookCar.java import java.sql.*; import java.util.List;

public class LookCar { public static void main(String args[]) { Connection con; Statement sql; ResultSet rs; try { Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); } catch (ClassNotFoundException e) { System.out.println("" + e); } try { con = DriverManager.getConnection("jdbc:odbc:mycar", "", ""); sql = con.createStatement(); rs = sql.executeQuery("INSERT INTO list VALUES('001','奔驰',390000,'2008-12-20')");// 向list表插入记录：('001','奔驰',390000,'2008-12-20') rs = sql.executeQuery("INSERT INTO list VALUES('002','奥迪',320000,'2009-07-20')");// 向list表插入记录：('002','奥迪',320000,'2009-07-20') rs = sql.executeQuery("INSERT INTO list VALUES('003','宝马',350000,'2009-10-10')");// 向list表插入记录：('003','宝马',350000,'2009-10-10') rs = sql.executeQuery("SELECT * FROM list"); while (rs.next()) { String number = rs.getString(1); String name = rs.getString(2); double price = rs.getDouble(3); Date madeDate = rs.getDate(4); System.out.println(number + "," + name + "," + price + ","+ madeDate); } rs = sql.executeQuery("UPDATE list SET price=380000 WHERE number='001'");// 将list表中number是001的price的值更新为380000 rs = sql.executeQuery("SELECT * FROM list WHERE number='001'");// 查询number为001的记录 boolean boo = rs.next(); if (boo) { String number = rs.getString(1); String name = rs.getString(2); double price = rs.getDouble(3); Date madeDate = rs.getDate(4); System.out.println(number + "," + name + "," + price + ","+ madeDate); } con.close(); } catch (SQLException e) { System.out.println(e); } } }

实验3 预处理语句 2．模板代码 Prepare.java import java.sql.*; import java.util.Calendar; public class Prepare { public static void main(String args[]) { Connection con; PreparedStatement pre; ResultSet rs; try { Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); } catch(ClassNotFoundException e){ System.out.println(""+e); } Calendar calendar=Calendar.getInstance(); calendar.set(2007,0,1); //注意0代表一月 Date date1=new Date(calendar.getTimeInMillis()); calendar.set(2007,5,1); Date date2=new Date(calendar.getTimeInMillis()); calendar.set(2008,10,1); Date date3=new Date(calendar.getTimeInMillis()); String [] number={"006","007","008"}; String [] name={"速腾","宝来","荣威"}; double [] price={168000,98000,260000}; Date [] date={date1,date2,date3}; try{ con=DriverManager.getConnection("jdbc:odbc:mycar","",""); String sql="SELECT * FROM list"; pre=con.prepareStatement(sql);//con调用prepareStatement()方法,sql做参数返回一个预处理语句 rs=pre.executeQuery(); while(rs.next()) { String nu=rs.getString(1); String na=rs.getString(2); double pr=rs.getDouble(3); Date madeDate=rs.getDate(4); System.out.println(nu+","+na+","+pr+","+madeDate); } pre=con.prepareStatement("INSERT INTO list VALUES(?,?,?,?)"); for(int i=0;ipre.setString(1, number[i]); //pre调用方法将条件中第1个?的值设置为number[i] pre.setString(2, name[i]);//pre调用方法将条件中第2个?的值设置为name[i] pre.setDouble(3,price[i]); //pre调用方法将条件中第3个?的值设置为price[i] pre.setDate(4, date[i]); //pre调用方法将条件中第4个?的值设置为date[i] pre.executeUpdate(); } pre=con.prepareStatement("SELECT * FROM list WHERE number>=?"); pre.setString(1,number[0]); //pre调用方法将条件中?的值设置为number[0] rs=pre.executeQuery(); while(rs.next()) { String nu=rs.getString(1); String na=rs.getString(2); double pr=rs.getDouble(3); Date madeDate=rs.getDate(4); System.out.println(nu+","+na+","+pr+","+madeDate); } pre=con.prepareStatement("UPDATE list SET price=? WHERE number=?"); pre.setDouble(1,159800); //pre调用方法将条件中第1个?的值的值设置为159800 pre.setString(2,number[0]); //pre调用方法将条件中第2个?的值设置为number[0] pre.executeUpdate(); pre=con.prepareStatement ("SELECT * FROM list Where number='"+number[0]+"'"); rs=pre.executeQuery(); boolean boo=rs.next(); if(boo) { String nu=rs.getString(1); String na=rs.getString(2); double pr=rs.getDouble(3); Date madeDate=rs.getDate(4); System.out.println(nu+","+na+","+pr+","+madeDate); } con.close(); } catch(SQLException e){ System.out.println(e); } } }

合集下载

Java程序设计教程-电子教案 第12章 Java高级编程

Java程序设计教程-电子教案 第12章 Java高级编程

例12-2 class Student{ String name; String nation; public void printInfo(){ System.out.println("I am "+name+", I am "+nation+"!"); } }
12.1 Java反射机制
public class Example12_2{ public static void main(String[] args){ Student stu = new Student(); = "LiMing"; stu.nation = "Chinese"; stu.printInfo(); } }
12.1 Java反射机制
String type = scan.next(); System.out.println("Please input price of product:"); double price = scan.nextDouble(); try{ Class c = Class.forName(className); SonyProduct sonyProduct = (SonyProduct)c.newInstance(); sonyProduct.type = type; sonyProduct.price = price; sonyProduct.printInfo(); }catch(ClassNotFoundException e){ System.out.println(e); }catch(InstantiationException e){ System.out.println(e); }catch(IllegalAccessException e){ System.out.println(e); } } }
java操作数据库的基本方法

java操作数据库的基本方法

java操作数据库的基本⽅法此次开发⼯具为eclipse,才有的数据库驱动是mysql-connector-java-5.1.8-bin.jar第⼀步,在eclipse的⼯程⽬录中引⽤mysql驱动选择build path 然后选择configure build path再选择libraries,选择add external library,找到之前下的数据库驱动,确认,ok然后下⼀段测试代码将数据库驱动起来public class test {public static void main(String []args) {try {//mysql数据库设置驱动程序类型Class.forName("com.mysql.jdbc.Driver");System.out.println("mysql数据库驱动加载成功");}catch(ClassNotFoundException e) {e.printStackTrace();}}}驱动代码运⾏⼀次就⾏了,之后就是操作数据库了基本操作增改删查,原理都是⼀样的先创建⼀个Connection对象Connection connection = null;String user="root";//⽤户名String password="19980713";//密码String url = "jdbc:mysql://localhost:3306/task?user="+user+"&password="+password+"&useUnicode=true&characterEncoding=utf-8";//获得连接的语句try{connection = (Connection)DriverManager.getConnection(url);}catch(SQLException e){e.printStackTrace();}获得连接之后就是对connection进⾏操作了查询记录String sql = "select id,name,job,department,state,authority from worker;";try {PreparedStatement ps = (PreparedStatement) connection.prepareStatement(sql);//预编译过程ResultSet rs = ps.executeQuery();//查询⼀般⽤executeQuery,返回的是查询的结果集//下⾯是对结果集进⾏操作while(rs.next()) {count++;Vector v = new Vector();v.add((rs.getString(1)));v.add((rs.getString(2)));v.add((rs.getString(3)));v.add((rs.getString(4)));v.add((rs.getString(5)));v.add((rs.getString(6)));worker.add(v);}}catch(SQLException e1) {e1.printStackTrace();}插⼊记录String sql = "insert into worker(name) "+"value("+ ""\"⼩明"\"" + ")";PreparedStatement ps = (PreparedStatement) connection.prepareStatement(sql);try {PreparedStatement ps = (PreparedStatement) connection.prepareStatement(sql);if(ps.executeUpdate()==1){//返回⼀个int值表⽰返回的条数int n = JOptionPane.showConfirmDialog(null, "添加成功,是否继续添加?", "系统提⽰",JOptionPane.YES_NO_OPTION);if(n == 0){//清空⾯板name.setText("");sex.setText("");authority.setText("");birthday.setText("");department.setText("");job.setText("");email.setText("");state.setText("");remark.setText("");specialty.setText("");address.setText("");tel.setText("");edu_level.setText("");}else{dispose();JoinNewMember frame = new JoinNewMember();}}} catch (SQLException e1) {// TODO Auto-generated catch blocke1.printStackTrace();}　其余操作就不贴代码了,以此类推就是的,我先准备⼀下六级去了,要不待会再来更新2018/06/16/18:39更新考完六级回来了段落匹配放最后⾯的没做完亏了⼗⼆⽉份再来哈哈哈哈补上:上⾯之所以不贴代码是因为套路都⼀样先实例化⼀个Connection对象,然后调⽤prepareStatement()将SQL语句带⼊其中进⾏预编译然后根据情况调⽤execute executeUpdate 或者executeQuery下⾯来了解⼀下这三个函数execute() executeQuery() executeUpdate()的区别和适⽤情况executeQuery()顾名思义----执⾏查询返回的是⼀个结果集,我们对结果集进⾏处理得到我们想要的数据.结果集的组成是⾏列的,⾏是指例句,列指属性,rs.next()可以看做⼀个迭代过程executeUpdate顾名思义---执⾏更新对应的⼀般就是⽤于执⾏ INSERT、UPDATE 或 DELETE或者⼀些定义数据库的语句,例如CREATE TABLE等,返回值是执⾏操作收到影响的⾏数关于execute,我刚开始以为挺简单的,后来才发现我低估了他的⽤途,我等菜鸟不敢随意总结,我在别的地⽅看到⼀个挺好的详解:。

Java与数据库的连接与操作

Java与数据库的连接与操作

Java与数据库的连接与操作在当今信息时代，数据库的使用变得不可或缺。

无论是企业还是个人，都需要对海量数据进行储存、管理和操作。

而Java作为一种功能强大的编程语言，具有广泛的应用范围，极其擅长与数据库的连接和操作。

本文将探讨Java与数据库的连接与操作的方法和技巧。

一、数据库的连接在使用Java与数据库进行交互之前，我们首先需要建立数据库的连接。

Java提供了多种方式与数据库进行连接，其中最常用和推荐的是使用JDBC（Java Database Connectivity）。

JDBC是Java为访问数据库而制定的一套API，它提供了一种标准的方法来连接和操作不同类型的数据库，包括关系型数据库如Oracle和MySQL，以及非关系型数据库如MongoDB。

在使用JDBC连接数据库时，我们首先需要加载数据库的驱动程序，然后根据数据库类型、用户名和密码等信息建立连接。

以下是一个使用JDBC连接MySQL数据库的示例代码：```javaimport java.sql.*;public class DatabaseConnection {public static void main(String[] args) {Connection conn = null;// 加载数据库驱动Class.forName("com.mysql.jdbc.Driver");// 建立连接conn =DriverManager.getConnection("jdbc:mysql://localhost:3306/mydatabase", "username", "password");// 进行数据库操作...} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();} finally {try {if (conn != null) {conn.close();}} catch (SQLException e) {e.printStackTrace();}}}```在以上代码中，我们首先使用`Class.forName()`方法加载MySQL数据库的驱动程序。

java对数据库操作的大集合

java对数据库操作的大集合

总结了几个项目中使用JDBC操作数据的常用方法，整理了一遍，不足自出还请纠正整体结构如下父类DatabasegetConnection()close()doExecute()isQueryExist()getSingleValue()getFirstRow()doQuery()子类Oracle Sybase SQLServer Mysql测试Java代码1.public static void main(String[] args) {2. //以sqlserver为例，获取一个DB对象3. Database db = DBFactory.getDB("sqlserver");4. String url = "jdbc:microsoft:sqlserver://localhost:7788;databaseName=t";5. //获取连接6. db.getConnection(url, "sa", "admin");7. //获取第一行数据，为了方便，自己写了个RowModel8. RowModel model= db.getFirstRow("select * from ismgtuser");9. //简单的输出10. for (int i = 0; i < model.getColumnCount(); i++) {11. System.out.print(model.getColumnValue(i+1)+" | ");12. }13. db.close();//关闭连接14. }DBFactory类Java代码1.public class DBFactory {2.3. /**4. * 获取数据库5. * @param dbTyle 数据库类型6. * dbTyle只有以下四种类型7. * dbTyle={mysql,sybase,oracle,sqlserver}8. * @return9. */10. public static Database getDB(String dbTyle){11. Database dbBase = null;12. if("mysql".equals(dbTyle))13. dbBase = new Mysql();14. else if("sybase".equals(dbBase))15. dbBase = new Sybase();16. else if("oracle".equals(dbBase))17. dbBase = new Oracle();18. else if("sqlserver".equals(dbTyle))19. dbBase = new SQLServer();20. return dbBase;21. }22.}Database类Java代码1.public abstract class Database {2.3. protected Connection conn = null;4.5. protected Statement st = null;6.7. /**8. * 获取数据库连接9. * @param url 连接URL10. * mysql.url = jdbc:mysql://localhost:port/dbName11. * rl = jdbc:sybase:Tds:localhost:port/dbName?CHARSET=cp93612. * oracle.url = jdbc:oracle:thin:@localhost:port:dbName13. * sqlserver.url = jdbc:microsoft:sqlserver://localhost:port;databaseName=?14. * @param user 用户名15. * @param password 密码16. * @return17. */18. public abstract Connection getConnection(String url, Stringuser, String password);19.20. /**21. * 关闭连接22. * @return23. */24. public boolean close(){25. try {26. if(st!=null)27. st.close();28. if(conn!=null)29. conn.close();30. return true;31. } catch (SQLException e) {32. System.err.println("关闭数据库连接失败："+e.getMessage());33. System.err.println(e);34. return false;35. }36. }37.38. /**39. * 批量执行SQL语句40. * @param sqls41. * @return42. */43. public boolean doExecute(String[] sqls) {44. try {45. conn.setAutoCommit(false);46. for(int i=0;i<sqls.length;i++)47. st.addBatch(sqls[i]);48. st.executeBatch();49. mit();50. return true;51. } catch (SQLException e) {52. try {53. conn.rollback();54. } catch (SQLException e1) {55. System.err.println("事务回滚失败："+e.getMessage());56. System.err.println(e);57. }58. System.err.println("执行sql语句失败："+e.getMessage());59. System.err.println(e);60. return false;61. }62. }63.64. /**65. * 判定SQL查询语句是否有结果66. * @param sql 查询语句67. * @return68. */69. @SuppressWarnings("unchecked")70. public boolean isQueryExist(String sql)71. {72. //sql不是以select关键开头73. if(sql!=null&&sql.toLowerCase().indexOf("select")>0){74. return false;75. }76. ArrayList row;77. try78. {79. row = doQuery(sql);80. RowModel model = (RowModel)row.get(0);81.82. return (Integer.parseInt(model.getColumnValue(1)) >0);83. }84. catch (Exception ex){85. System.out.println(ex.getMessage());86. }87. return false;88. }89.90. /**91. * 获取单个值-如果查询结果是多行多列数据，则只返回第一行第一列的值92. * @param sql 查询语句93. * @return94. */95. @SuppressWarnings("unchecked")96. public String getSingleValue(String sql)97. {98. ArrayList row;99. try100. {101. row = doQuery(sql);102. RowModel model = (RowModel)row.get(0); 103. return model.getColumnValue(1);104. }105. catch (Exception ex) {106. }107. return null;108. }109.110. /**111. * 获取第一行数据-如果有多行，则只返回第一行数据112. * @param sql 查询语句113. * @return114. */115.@SuppressWarnings("unchecked")116. public RowModel getFirstRow(String sql)117. {118. ArrayList list;119. try120. {121. list = doQuery(sql);122. if (list.size() == 0)123. return null;124.125. return ((RowModel)list.get(0));126. }127. catch (Exception ex) {128. System.out.println(ex.getMessage()); 129. return null;130. }131. }132.133. /**134. * 查询数据，多行多列135. * @param sql 查询语句136. * @return137. */138.@SuppressWarnings("unchecked")139. public ArrayList doQuery(String sql) {140. ArrayList rows = new ArrayList();141. try {142. ResultSet rs = st.executeQuery(sql);143. ResultSetMetaData rsmd = rs.getMetaData(); //获取结果集144. int columnCount = rsmd.getColumnCount();//获取列个数145. String[] column = new String[columnCount];146. for (int i = 0; i < columnCount; ++i) { 147. column[i] = rsmd.getColumnLabel(i + 1).toU pperCase();148. if ((column[i] == null) || (column[i].trim ().equals("")))149. column[i] = "_COLUMN_" + (i + 1);150. }151. RowModel rowModel = null;152. while(rs.next()){153. rowModel = new RowModel(column);154. for(int i=0;i<columnCount;i++)155. rowModel.setColumnValue(i + 1, rs.getS tring(i + 1));156. rows.add(rowModel);157. }158. return rows;159. } catch (SQLException e) {160. System.err.println("查询失败："+e.getMessage());161. System.err.println(e);162. return null;163. }164. }165.}SQLServer类Java代码1.public class SQLServer extends Database {2.3.@Override4. public Connection getConnection(String url, String user, String password) {5. if(url==null||"".equals(url)||user==null||"".equals(user))6. return null;7. try {8. DriverManager.registerDriver(new SQLServerDriver());9. Connection conn = DriverManager.getConnection(url,user, password);10. super.conn = conn;11. super.st = conn.createStatement();12. return conn;13. } catch (SQLException e) {14. System.err.println("获取SQLServer连接失败:"+e.getMessage());15. System.err.println(e);16. }17. return null;18. }19.20.21.}其他几个类就不一一贴出来了，需要可以下载jar包查看最后附上生成的jar包，相关数据库的驱动jar包就不附在里面了。