51Testing软件测试论坛

 找回密码
 (注-册)加入51Testing

QQ登录

只需一步,快速开始

微信登录,快人一步

手机号码,快捷登录

查看: 1512|回复: 0
打印 上一主题 下一主题

Java对MySQL数据库进行操作

[复制链接]
  • TA的每日心情
    无聊
    昨天 09:06
  • 签到天数: 530 天

    连续签到: 2 天

    [LV.9]测试副司令

    跳转到指定楼层
    1#
    发表于 2018-12-14 16:45:18 | 只看该作者 回帖奖励 |倒序浏览 |阅读模式
    数据库几乎是每一个应用型的程序都会用到,学会如何高效操作数据库也是开发一个重点。今天我总结了具体的操作步骤以及注意点。Java访问数据库主要用的方法是JDBC,它是java语言中用来规范客户端程序如何来访问数据库的应用程序接口,提供了诸如查询和更新数据库中数据的方法,接下来进行总结。

    一、操作的一般过程


    1、连接数据库

    2、调用Class.forName()方法加载驱动程序。

    3、调用DriverManager对象的getConnection()方法,获得一个Connection对象。

    4、创建一个Statement对象,准备一个SQL语句,这个SQL语句可以是Statement对象(立即执行的的语句)、PreparedStatement语句(预编译的语句)或CallableStatement对象(存储过程调用的语句)。

    5、调用excuteQuery()等方法执行SQL语句,并将结果保存在ResultSet对象;或者调用executeUpdate()等方法执行SQL语句,不返回ResultSet对象的结果。

    6、对返回的ResultSet对象进行显示等相当的处理。

    7、释放资源。

    二、Java访问数据库的具体步骤
    1、连接数据库


    (1) 下载Mysql连接驱动

    (2) 加载JDBC驱动

    操作方法:在Eclipse中,选中相应的工程,点击Project-Properties中的Java Build Path,在Libraries中增加mysql-connector-java-5.1.21-bin.jar,点OK。

    (3) 建一个简单的测试数据库如下:



    2、加载JDBC驱动程序


    • 在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机),这通过java.lang.Class类的静态方法forName(String  className)实现。
    代码如下:
    1. <span style="font-family:Microsoft YaHei;font-size:14px;"> try{   
    2.       //加载MySql的驱动类   
    3.       Class.forName("com.mysql.jdbc.Driver");
    4.       System.out.println("驱动加载成功!");      
    5. }catch(ClassNotFoundException e){   
    6.       System.out.println("找不到驱动程序类 ,加载驱动失败!");   
    7.       e.printStackTrace() ;   
    8. }</span><span style="font-family:Microsoft YaHei;font-size:14px;">
    9. </span>
    复制代码
    如果成功加载,那么Driver的实例就会注册到DriverManager类中。
    3、创建数据库的连接
    1)连接URL定义了连接数据库时的协议、子协议、数据源标识。   
    2)书写形式:协议:子协议:数据源标识  
         协议:在JDBC中总是以jdbc开始   
         子协议:是桥连接的驱动程序或是数据库管理系统名称。   
         数据源标识:标记找到数据库来源的地址与连接端口。
    1. <p> //连接MySql数据库,用户名和密码都是root   </p><p>     String url = "jdbc:mysql://localhost:3306/test" ;    </p><p>     String username = "root" ;   </p><p>     String password = "root" ;   </p><p>     try{   </p><p>            Connection con = DriverManager.getConnection(url , username , password ) ;   </p><p>     }catch(SQLException se){   </p><p>            System.out.println("数据库连接失败!");   </p><p>            se.printStackTrace() ;   </p><p>     } </p><p></p>
    复制代码
    4、创建Statement对象
    要执行SQL语句,必须获得java.sql.Statement实例,Statement实例分为以下3种类型:   
    1)执行静态SQL语句。通常通过Statement实例实现。   
    2)执行动态SQL语句。通常通过PreparedStatement实例实现。   
    3)执行数据库存储过程。通常通过CallableStatement实例实现。
    具体的实现方式如下:
    1. Statement stmt = con.createStatement() ;   
    2. reparedStatement pstmt = con.prepareStatement(sql) ;   
    3. CallableStatement cstmt = con.prepareCall("{CALL demoSp(? , ?)}") ;
    复制代码
    5、执行SQL语句
    Statement接口提供了三种执行SQL语句的方法:executeQuery 、executeUpdate  和execute  。
    1)ResultSet executeQuery(String sqlString):执行查询数据库的SQL语句   ,返回一个结果集(ResultSet)对象。   
    2)int executeUpdate(String sqlString):用于执行INSERT、UPDATE或  DELETE语句以及SQL DDL语句,如:CREATE TABLE和DROP TABLE等   
    3)execute(sqlString):用于执行返回多个结果集、多个更新计数或二者组合的语句。   
    例如:
    1. //数据库查询语句
    2. String sql = "select * from users";//要执行的SQL
    3.                                
    4. /*在询数据表时,需要用到ResultSet接口,它类似于一个数据表,通过该接口的实例可以获得检索结果集,以及对应数据表的接口信息。*/
    5. ResultSet rs = stmt.executeQuery(sql);//创建数据对象
    复制代码
    6、处理ResultSet对象
    两种情况:   
    1)执行更新返回的是本次操作影响到的记录数。   
    2)执行查询返回的结果是一个ResultSet对象。   
    ResultSet包含符合SQL语句中条件的所有行,并且它通过一套get方法提供了对这些行中数据的访问。   
    例如执行查询数据库表:
    1. //数据库查询语句
    2. String sql = "select * from users";//要执行的SQL
    3.                                
    4. /*在询数据表时,需要用到ResultSet接口,它类似于一个数据表,通过该接口的实例可以获得检索结果集,以及对应数据表的接口信息。*/
    5. ResultSet rs = stmt.executeQuery(sql);//创建数据对象
    6.                                
    7. System.out.println("编 号"+"\t"+"姓 名"+"\t"+"密 码"+"\t"+"邮 箱");
    8. //遍历查询的结果集
    9. while (rs.next()) {
    10.         System.out.print(rs.getInt(1)+"\t");
    11.         System.out.print(rs.getString(2)+"\t");
    12.         System.out.print(rs.getString(3)+"\t");
    13.         System.out.print(rs.getString(4)+"\t");
    14.         System.out.println();
    15. }
    复制代码
    7、关闭JDBC对象,释放资源


    • 操作完成以后要把所有使用的JDBC对象全都关闭,以释放JDBC资源,关闭顺序和声明顺序相反:   
    • 1)关闭记录集   
    • 2)关闭声明   
    • 3)关闭连接对象   
    1. //关闭连接
    2. rs.close();
    3. stmt.close();
    4. conn.close();
    复制代码
    最后附上完整的查询和插入数据代码。

    1、查询数据库

    1. import java.sql.*;

    2. public class SelectTable {
    3.         public static void main(String[] args) {
    4.                 try {
    5.                         //1.调用Class.forName()方法加载驱动程序
    6.                         Class.forName("com.mysql.jdbc.Driver");
    7.                         System.out.println("成功加载MySQL驱动!");
    8.                        
    9.                         String url= "jdbc:mysql://localhost:3306/test";//JDBC的URL
    10.                         String rootName = "root";
    11.                         String pwd ="root";
    12.                        
    13.                         //2.建立连接
    14.                         //调用DriverManager对象的getConnection()方法,获得一个Connection对象
    15.                         Connection conn= null;
    16.                         //创建Statement对象
    17.                         Statement stmt  = null;
    18.                        
    19.                         try {
    20.                                 //建立数据库连接
    21.                                 conn = DriverManager.getConnection(url,rootName,pwd);
    22.                                 stmt  = conn.createStatement();//创建一个Statement对象
    23.                                 System.out.println("成功连接到数据库~");
    24.                                
    25.                                 //数据库查询语句
    26.                                 String sql = "select * from users";//要执行的SQL
    27.                                
    28.                                 /*在询数据表时,需要用到ResultSet接口,它类似于一个数据表,通过该接口的实例
    29.                                  * 可以获得检索结果集,以及对应数据表的接口信息。*/
    30.                                 ResultSet rs = stmt.executeQuery(sql);//创建数据对象
    31.                                
    32.                                 System.out.println("编 号"+"\t"+"姓 名"+"\t"+"密 码"+"\t"+"邮 箱");
    33.                                 //遍历查询的结果集
    34.                                 while (rs.next()) {
    35.                                         System.out.print(rs.getInt(1)+"\t");
    36.                                         System.out.print(rs.getString(2)+"\t");
    37.                                         System.out.print(rs.getString(3)+"\t");
    38.                                         System.out.print(rs.getString(4)+"\t");
    39.                                         System.out.println();
    40.                                 }
    41.                                 //关闭连接
    42.                                 rs.close();
    43.                 stmt.close();
    44.                 conn.close();
    45.                         } catch (SQLException e) {
    46.                                 e.printStackTrace();
    47.                         }                       
    48.                 } catch (ClassNotFoundException e) {
    49.                         e.printStackTrace();
    50.                 }
    51.        
    52.         }
    53. }
    复制代码

    2、插入数据

    1. import java.sql.Connection;
    2. import java.sql.DriverManager;
    3. import java.sql.PreparedStatement;
    4. import java.sql.ResultSet;
    5. import java.sql.SQLException;
    6. import java.sql.Statement;


    7. public class InsertData {
    8.         public static void main(String[] args) {
    9.                 try {
    10.                         //1.调用Class.forName()方法加载驱动程序
    11.                         Class.forName("com.mysql.jdbc.Driver");
    12.                         System.out.println("成功加载MySQL驱动!");
    13.                        
    14.                         String url= "jdbc:mysql://localhost:3306/test";//JDBC的URL
    15.                         String rootName = "root";
    16.                         String pwd ="root";
    17.                        
    18.                         //2.建立连接
    19.                         //调用DriverManager对象的getConnection()方法,获得一个Connection对象
    20.                         Connection conn= null;
    21.                         //创建Statement对象
    22.                         Statement stmt  = null;
    23.                        
    24.                         try {
    25.                                 //建立数据库连接
    26.                                 conn = DriverManager.getConnection(url,rootName,pwd);
    27.                                 stmt  = conn.createStatement();//创建一个Statement对象
    28.                                 System.out.println("成功连接到数据库~");
    29.                                
    30.                                 //刷新的sql语句
    31.                                 String sql = "insert into users values(2,'ajax','ajax','ajax@qq.com')";
    32.                                 //建立PreparedStatement对象
    33.                                 PreparedStatement pst = conn.prepareStatement(sql);
    34.                     pst.executeUpdate();
    35.                     //System.out.println(pst);
    36.                            
    37.                     String sql3 = "select * from users";//要执行的SQL
    38.                                
    39.                                 /*在询数据表时,需要用到ResultSet接口,它类似于一个数据表,通过该接口的实例
    40.                                  * 可以获得检索结果集,以及对应数据表的接口信息。*/
    41.                                 ResultSet rs = stmt.executeQuery(sql3);//创建数据对象
    42.                                
    43.                                 System.out.println("编 号"+"\t"+"姓 名"+"\t"+"密 码"+"\t"+"邮 箱");
    44.                                 //遍历查询的结果集
    45.                                 while (rs.next()) {
    46.                                         System.out.print(rs.getInt(1)+"\t");
    47.                                         System.out.print(rs.getString(2)+"\t");
    48.                                         System.out.print(rs.getString(3)+"\t");
    49.                                         System.out.print(rs.getString(4)+"\t");
    50.                                         System.out.println();
    51.                                 }
    52.                                
    53.                                 //关闭连接
    54.                                 rs.close();
    55.                 stmt.close();
    56.                 conn.close();
    57.                         } catch (SQLException e) {
    58.                                 e.printStackTrace();
    59.                         }                       
    60.                 } catch (ClassNotFoundException e) {
    61.                         e.printStackTrace();
    62.                 }
    63.        
    64.         }
    65. }
    复制代码




    本帖子中包含更多资源

    您需要 登录 才可以下载或查看,没有帐号?(注-册)加入51Testing

    x
    分享到:  QQ好友和群QQ好友和群 QQ空间QQ空间 腾讯微博腾讯微博 腾讯朋友腾讯朋友
    收藏收藏
    回复

    使用道具 举报

    本版积分规则

    关闭

    站长推荐上一条 /1 下一条

    小黑屋|手机版|Archiver|51Testing软件测试网 ( 沪ICP备05003035号 关于我们

    GMT+8, 2024-11-22 11:35 , Processed in 0.071361 second(s), 24 queries .

    Powered by Discuz! X3.2

    © 2001-2024 Comsenz Inc.

    快速回复 返回顶部 返回列表