JAVA操作MySQL数据库

俊才

发布于 2021-01-03 15:01:50

2.7K00

代码可运行

文章被收录于专栏：数据库干货铺数据库干货铺

运行总次数：0

代码可运行

JAVA操作MySQL数据库，涉及创建连接，创建表，插入数据，更新数据，查询数据

总体步骤：

1) 获取驱动(可以省略)

2) 获取连接

　　Connection 接口，代表一个连接对象 ,具体的实现类由数据库的厂商实现

　　使用 DriverManager类的静态方法,getConnection可以获取数据库的连接

3) 获取Statement对象通过Connection 的 createStatement方法获取sql语句执行对象

4) 处理结果集(只在查询时处理)

5) 释放资源

代码如下：

package jdbc;import java.sql.*;
public class Test01 {    public static void main(String[] args) throws ClassNotFoundException, SQLException {　　　　　//使用驱动;        Class.forName("com.mysql.jdbc.Driver");　　　　 // 创建连接，涉及数据库IP，端口，数据库名，字符集，账号及密码        String url = "jdbc:mysql://127.0.0.1:3307/testdb?characterEncoding=UTF-8";        Connection conn = DriverManager.getConnection(url,"root","Root#123456");        //System.out.println(conn);        // 获取语句执行平台对象 Statement        Statement smt = conn.createStatement();        // 创建表 executeUpdate方法        String  sql1  = "create table  if not exists test14(id int  primary key auto_increment ,name varchar(20),age int);";        smt.executeUpdate(sql1);        //  插入数据        String sql_i = "insert into  test14 values(1,'刘备',45),(2,'关羽',40),(3,'张飞',37),(4,'赵云',30),(5,'诸葛亮',27);";        smt.executeUpdate(sql_i);
        // 更新数据        String sql_u= "update  test14 set age = 36 where name='张飞';";        smt.executeUpdate(sql_u);
        // 查询结果        String  sql_q = "select  * from  test14;";        ResultSet res = smt.executeQuery(sql_q);        while(res.next()){            int    id = res.getInt(1);            String  name= res.getString("name");            int  age = res.getInt("age");            System.out.println("id:"+ id + "    name:" + name +"    age:"+age);        }

        // 关闭流 (先开后关)        res.close();        smt.close();        conn.close();
    }
}

结果如下：