java操作mysql实现增删改查的方法

本文实例讲述了java操作mysql实现增删改查的方法。分享给大家供大家参考，具体如下：

首先，需要把MySQL与Java连接的jar（mysql-connector-java-5.1.6-bin.jar）包导入工程.

package com.cn.edu;
import java.beans.Statement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class helloworld {
  private Connection conn = null;
  PreparedStatement statement = null;
  // connect to MySQL
  void connSQL() {
    String url = "jdbc:mysql://localhost:3306/hello?characterEncoding=UTF-8";
    String username = "root";
    String password = "root"; // 加载驱动程序以连接数据库
    try {
      Class.forName("com.mysql.jdbc.Driver" );
      conn = DriverManager.getConnection( url,username, password );
      }
    //捕获加载驱动程序异常
     catch ( ClassNotFoundException cnfex ) {
       System.err.println(
       "装载 JDBC/ODBC 驱动程序失败。" );
       cnfex.printStackTrace();
     }
     //捕获连接数据库异常
     catch ( SQLException sqlex ) {
       System.err.println( "无法连接数据库" );
       sqlex.printStackTrace();
     }
  }
  // disconnect to MySQL
  void deconnSQL() {
    try {
      if (conn != null)
        conn.close();
    } catch (Exception e) {
      System.out.println("关闭数据库问题 ：");
      e.printStackTrace();
    }
  }
  // execute selection language
  ResultSet selectSQL(String sql) {
    ResultSet rs = null;
    try {
      statement = conn.prepareStatement(sql);
      rs = statement.executeQuery(sql);
    } catch (SQLException e) {
      e.printStackTrace();
    }
    return rs;
  }
  // execute insertion language
  boolean insertSQL(String sql) {
    try {
      statement = conn.prepareStatement(sql);
      statement.executeUpdate();
      return true;
    } catch (SQLException e) {
      System.out.println("插入数据库时出错：");
      e.printStackTrace();
    } catch (Exception e) {
      System.out.println("插入时出错：");
      e.printStackTrace();
    }
    return false;
  }
  //execute delete language
  boolean deleteSQL(String sql) {
    try {
      statement = conn.prepareStatement(sql);
      statement.executeUpdate();
      return true;
    } catch (SQLException e) {
      System.out.println("插入数据库时出错：");
      e.printStackTrace();
    } catch (Exception e) {
      System.out.println("插入时出错：");
      e.printStackTrace();
    }
    return false;
  }
  //execute update language
  boolean updateSQL(String sql) {
    try {
      statement = conn.prepareStatement(sql);
      statement.executeUpdate();
      return true;
    } catch (SQLException e) {
      System.out.println("插入数据库时出错：");
      e.printStackTrace();
    } catch (Exception e) {
      System.out.println("插入时出错：");
      e.printStackTrace();
    }
    return false;
  }
  // show data in ju_users
  void layoutStyle2(ResultSet rs) {
    System.out.println("-----------------");
    System.out.println("执行结果如下所示:");
    System.out.println("-----------------");
    System.out.println(" 用户ID" + "/t/t" + "淘宝ID" + "/t/t" + "用户名"+ "/t/t" + "密码");
    System.out.println("-----------------");
    try {
      while (rs.next()) {
        System.out.println(rs.getInt("ju_userID") + "/t/t"
            + rs.getString("taobaoID") + "/t/t"
            + rs.getString("ju_userName")
             + "/t/t"+ rs.getString("ju_userPWD"));
      }
    } catch (SQLException e) {
      System.out.println("显示时数据库出错。");
      e.printStackTrace();
    } catch (Exception e) {
      System.out.println("显示出错。");
      e.printStackTrace();
    }
  }
  public static void main(String args[]) {
    helloworld h = new helloworld();
    h.connSQL();
    String s = "select * from ju_users";
    String insert = "insert into ju_users(ju_userID,TaobaoID,ju_userName,ju_userPWD) values("+8329+","+34243+",'mm','789')";
    String update = "update ju_users set ju_userPWD =123 where ju_userName= 'mm'";
    String delete = "delete from ju_users where ju_userName= 'mm'";
    if (h.insertSQL(insert) == true) {
      System.out.println("insert successfully");
      ResultSet resultSet = h.selectSQL(s);
      h.layoutStyle2(resultSet);
    }
    if (h.updateSQL(update) == true) {
      System.out.println("update successfully");
      ResultSet resultSet = h.selectSQL(s);
      h.layoutStyle2(resultSet);
    }
    if (h.insertSQL(delete) == true) {
      System.out.println("delete successfully");
      ResultSet resultSet = h.selectSQL(s);
      h.layoutStyle2(resultSet);
    }
    h.deconnSQL();
  }
}

notice:

1、现在一般用的驱动是com.mysql.jdbc.Driver，以前的那个什么org的驱动虽然封装了com.mysql.jdbc.Driver，但不好用，过时了。

2、prepareStatement(sql)是statement的子类，比statement好用。

3、如果数据库中定义的是int值，那么sql语句中要把int单独提出来。如".....values("+8329+","+34243+",'mm','789')"

更多关于java相关内容感兴趣的读者可查看本站专题：《Java数据结构与算法教程》、《Java文件与目录操作技巧汇总》、《Java操作DOM节点技巧总结》和《Java缓存操作技巧汇总》

希望本文所述对大家java程序设计有所帮助。

# java # mysql # 增删改查 # java连接mongoDB并进行增删改查操作实例详解 # mongodb增删改查详解_动力节点Java学院整理 # Java连接MongoDB进行增删改查的操作 # java jdbc连接mysql数据库实现增删改查操作 # Java语言实现对MySql数据库中数据的增删改查操作的代码 # JavaWeb应用实例:用servlet实现oracle 基本增删改查 # Java连接MySQL数据库增删改查的通用方法(推荐) # java 数据库连接与增删改查操作实例详解 # mybatis教程之增删改查_动力节点Java学院整理 # java连接Mongodb实现增删改查 # 连接数据库 # 好用 # 的是 # 操作技巧 # 加载 # 相关内容 # 子类 # 感兴趣 # 要把 # 数据结构 # 给大家 # 所示 # 淘宝 # 但不 # 更多关于 # 装了 # 所述 # 数据库中 # 程序设计 # 讲述了

返回目录在线咨询

上一篇：美食网站图片处理：如何让食物照片更诱人？
下一篇：C++如何将十六进制转为十进制_C++ stoul与stringstream转换方法

您的项目需求

*请认真填写需求信息，我们会在24小时内与您取得联系。

全网整合营销服务商

java操作mysql实现增删改查的方法

您的项目需求