java语言MySQL批管理

java语言MySQL批处理

本质来讲就是使用Statement和PreStatement的addBatch()方法

代码

import java.sql.*;

public class GetConnection{
 public static void main(String[] args){
  Access2Database adb=new Access2Database();
  Connection conn=adb.getConn(); 

  //transaction dealing
  PreparedStatement pstam=null;
  try{
   conn.setAutoCommit(false);
   String sql="insert into student(name,major,score) values(?,?,?);";
   pstam=conn.prepareStatement(sql);
   pstam.setString(1, "f");
   pstam.setString(2,"History");
   pstam.setInt(3, 67);
   pstam.addBatch();
   pstam.setString(1, "h");
   pstam.setString(2, "Biology");
   pstam.setInt(3, 85);
   pstam.addBatch();
   pstam.executeBatch();
   conn.commit();
  }catch(SQLException e){
   try {
    conn.rollback();
   } catch (SQLException e1) {
    // TODO Auto-generated catch block
    e1.printStackTrace();
   }
   e.printStackTrace();
  }finally{
   try {
    conn.setAutoCommit(true);
   } catch (SQLException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
  } 

  //release the resource of the program
  try{
   pstam.close();
   conn.close();
  }catch(SQLException e){
   e.printStackTrace();
  }
 }
}

图片 1

本质来讲就是使用Statement和PreStatement的addBatch()方法 代码 import
java.sql.*;public class GetConnection{public static void
main(String[] ar…

JDBC是一组能够执行SQL语句的API

JDBC是一组能够执行SQL语句的API

由于传统的数据库操作方式需要程序员掌握各个不同的数据库的API,极其不便

由于传统的数据库操作方式需要程序员掌握各个不同的数据库的API,极其不便

因此java定义了JDBC这一标准的接口和类,为程序员操作数据库提供了统一的方式

因此java定义了JDBC这一标准的接口和类,为程序员操作数据库提供了统一的方式

**JDBC的操作方式比较单一,由五个流程组成:

**JDBC的操作方式比较单一,由五个流程组成:

**1.通过数据库厂商提供的JDBC类库向DriverManager注册数据库驱动

**1.通过数据库厂商提供的JDBC类库向DriverManager注册数据库驱动

2.使用DriverManager提供的getConnection()方法连接到数据库

2.使用DriverManager提供的getConnection()方法连接到数据库

3.通过数据库的连接对象的createStatement方法建立SQL语句对象

3.通过数据库的连接对象的createStatement方法建立SQL语句对象

4.执行SQL语句,并将结果集合返回到ResultSet中

4.执行SQL语句,并将结果集合返回到ResultSet中

5.使用while循环读取结果

5.使用while循环读取结果

6.关闭数据库资源

6.关闭数据库资源

下面来看看具体操作Mysql数据库的方法

下面来看看具体操作Mysql数据库的方法

准备工作

准备工作

首先我们需要建立一个数据库和一张简单的表

首先我们需要建立一个数据库和一张简单的表

复制代码 代码如下:

复制代码 代码如下:

mysql> create database person;
Query OK, 1 row affected (0.00 sec)

mysql> create database person;
Query OK, 1 row affected (0.00 sec)

mysql> use person;
Database changed
mysql> create table student(
    -> id int,
    -> name varchar(20),
    -> birth year
    -> ) default charset=utf8;
Query OK, 0 rows affected (0.10 sec)

mysql> use person;
Database changed
mysql> create table student(
    -> id int,
    -> name varchar(20),
    -> birth year
    -> ) default charset=utf8;
Query OK, 0 rows affected (0.10 sec)

然后往里面插入几条数据

然后往里面插入几条数据

复制代码 代码如下:

复制代码 代码如下:

mysql> insert into student values
    -> (1,’张三’,1990),
    -> (2,’李四’,1991),
    -> (3,’王五’,1992);
Query OK, 3 rows affected (0.02 sec)
Records: 3  Duplicates: 0  Warnings: 0

mysql> insert into student values
    -> (1,’张三’,1990),
    -> (2,’李四’,1991),
    -> (3,’王五’,1992);
Query OK, 3 rows affected (0.02 sec)
Records: 3  Duplicates: 0  Warnings: 0

这样一张简单的表就建好了

这样一张简单的表就建好了

复制代码 代码如下:

复制代码 代码如下:

mysql> select * from student;
+——+——–+——-+
| id   | name   | birth |
+——+——–+——-+
|    1 | 张三   |  1990 |
|    2 | 李四   |  1991 |
|    3 | 王五   |  1992 |
+——+——–+——-+
 rows in set (0.00 sec)

mysql> select * from student;
+——+——–+——-+
| id   | name   | birth |
+——+——–+——-+
|    1 | 张三   |  1990 |
|    2 | 李四   |  1991 |
|    3 | 王五   |  1992 |
+——+——–+——-+
 rows in set (0.00 sec)

接下来,去mysql官网下载数据库连接器这个包

接下来,去mysql官网下载数据库连接器这个包

其中这个包里面含有一份文档,里面列举了基本的使用方法,可以参考

其中这个包里面含有一份文档,里面列举了基本的使用方法,可以参考

我们的操作也是按照这份文档中的内容进行,然后最主要的地方就是导入这个jar包

我们的操作也是按照这份文档中的内容进行,然后最主要的地方就是导入这个jar包

图片 2

图片 3

为了操作方便,这里使用eclipse来导入

为了操作方便,这里使用eclipse来导入

右键项目–>构件路径–>添加外部归档,添加好了之后如下所示

右键项目–>构件路径–>添加外部归档,添加好了之后如下所示

图片 4

图片 5

现在我们正式开始使用java来操作mysql数据库

现在我们正式开始使用java来操作mysql数据库

JDBC操作实例1:最简单的查询操作

JDBC操作实例1:最简单的查询操作

复制代码 代码如下:

复制代码 代码如下:

import java.sql.*;

import java.sql.*;

public class Demo {
    //为了代码紧凑性,暂时抛出所有异常
    public static void main(String[] args) throws Exception {
        //注册数据库驱动
        Class.forName(“com.mysql.jdbc.Driver”);
        //建立数据库连接
       
//参数一:jdbc:mysql//地址:端口/数据库,参数二:用户名,参数三:密码
        Connection conn = DriverManager.getConnection
                (“jdbc:mysql://localhost:3306/person”,”root”,”admin”);
        //创建SQL语句
        Statement st = conn.createStatement();
        //执行语句,返回结果
        ResultSet rt = st.executeQuery(“show tables”);
        //循环取出结果
        while(rt.next()) {
            //获取字段
            System.out.println(rt.getString(“Tables_in_person”));
        }
        //关闭资源,最先打开的最后关
        rt.close();
        st.close();
        conn.close();
    }
}

public class Demo {
    //为了代码紧凑性,暂时抛出所有异常
    public static void main(String[] args) throws Exception {
        //注册数据库驱动
        Class.forName(“com.mysql.jdbc.Driver”);
        //建立数据库连接
       
//参数一:jdbc:mysql//地址:端口/数据库,参数二:用户名,参数三:密码
        Connection conn = DriverManager.getConnection
                (“jdbc:mysql://localhost:3306/person”,”root”,”admin”);
        //创建SQL语句
        Statement st = conn.createStatement();
        //执行语句,返回结果
        ResultSet rt = st.executeQuery(“show tables”);
        //循环取出结果
        while(rt.next()) {
            //获取字段
            System.out.println(rt.getString(“Tables_in_person”));
        }
        //关闭资源,最先打开的最后关
        rt.close();
        st.close();
        conn.close();
    }
}