频道栏目
首页 > 资讯 > MySQL > 正文

JDBC----用JDBC连接Mysql并进行增删改查操作

17-06-19        来源:[db:作者]  
收藏   我要投稿

一,JDBC:Java数据库连接,(Java Database Connectivity,简称JDBC)是Java语言中用来规范客户端程序如何访问数据库的应用程序接口,提供了诸如查询和更新数据库中数据的方法。

二,简单的JDBC实例

我使用JDBC写的一个简单程序,主要是使用JDBC连接Mysql数据库,然后对数据库进行一些基本的增删改查操作。

1,设计数据表

先设计一张数据表,用户保存用户信息,建表语句如下:

CREATE TABLE `person` (
 `id` int(11) NOT NULL,
 `name` text NOT NULL,
 `phone` varchar(255) CHARACTER SET latin1 DEFAULT NULL,
 `age` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

在person表中定义了几个字段,分别是id,name,phone,age,其中id是主键,是自增长,name表示用户名,phone是用户的手机,age是用户的年龄。

预先在数据库中插入几条数据,数据如下:

这里写图片描述

2,定义实体类

定义一个Bean,与数据库表中的各个字段对应:

public class Person {

private int id;
private String name;
private String phone;
private int age;

public int getId() {
    return id;
}
public void setId(int id) {
    this.id = id;
}
public String getName() {
    return name;
}
public void setName(String name){
    this.name = name;
}
public String getPhone() {
    return phone;
}
public void setPhone(String phone) {
    this.phone = phone;
}
public int getAge() {
    return age;
}
public void setAge(int age) {
    this.age = age;
}
public String toString() {
    return "Person [id=" + id + ", name=" + name + ", phone=" + phone
            + ", age=" + age + "]";
}
public Person(int id, String name, String phone, int age) {
    super();
    this.id = id;
    this.name = name;
    this.phone = phone;
    this.age = age;
}
public Person() {
    super();
    // TODO Auto-generated constructor stub
}
}

3,定义数据库连接类
定义一个数据看连接类,用户获取Mysql的连接

public class DBUtil {

private static String URL = "jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf-8";
private static String Driver = "com.mysql.jdbc.Driver";
private static String user = "root";
private static String password = "";

public static Connection connectDB() throws Exception {
    Class.forName(Driver);
    Connection conn = DriverManager.getConnection(URL, user, password);

    return conn;
}
}

Mysql的JDBC URL编写方式为:jdbc:mysql//主机名称:连接端口/数据库名称?参数=值,为了避免中文乱码要指定useUnicode和characterEncoding.因为连接的是Mysql数据库,所以程序一开始需要加载Mysql的数据库驱动,然后通过DriverManager.getConnection(String URL)方法获取数据库的连接。

4,实现数据库的增删改查

获取了数据库的连接之后,就可以操作数据库了,下面分别实现数据库的增删改查操作,定义了一个PersonDao类用于操作数据库.

1)查询

先看查询操作,在PersonDao中定义了一个queryAll()方法:

public List queryAll() throws Exception {
    Connection conn = DBUtil.connectDB();
    String sql = "SELECT * FROM person";
    List personList = new ArrayList();

    Statement stmt = conn.createStatement();
    ResultSet rs = stmt.executeQuery(sql);
    while (rs.next()) {
        Person person = new Person();
        person.setId(rs.getInt("id"));
        person.setName(rs.getString("name"));
        person.setPhone(rs.getString("phone"));
        person.setAge(rs.getInt("age"));

        personList.add(person);
    }

    return personList;
}

这里使用conn.createStatement()方法获取一个Statement对象,这个对象里面有很多方法可以操作数据库,使用executeQuery(sql)执行查询操作,查询结果为一个结果集ResultSet,可以通过这个结果集获取相关信息。

定义main函数:

public static void main(String[] args){
    PersonDao dao = new PersonDao();

    try {
        List personList = dao.queryAll();
        for (Person person : personList) {
            System.out.println(person);
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
   }

执行结果:

Person [id=10, name=胡春, phone=18229096647, age=34]
Person [id=11, name=王菲, phone=18229096640, age=21]
Person [id=12, name=刘明, phone=18229096649, age=22]
Person [id=13, name=白云, phone=18229096646, age=25]
Person [id=15, name=黄土, phone=18229096644, age=20]

根据条件查询,定义一个queryByParams方法:

public List queryParams(List<>> params) throws Exception {
    Connection conn = DBUtil.connectDB();
    String sql = "SELECT * FROM person WHERE 26=26";

    System.out.println(sql.toString());

    List personList = new ArrayList();

    Statement stmt = conn.createStatement(); 
    ResultSet rs = stmt.executeQuery(sql.toString());
    while (rs.next()) {
        Person person = new Person();
        person.setId(rs.getInt("id"));
        person.setName(rs.getString("name"));
        person.setPhone(rs.getString("phone"));
        person.setAge(rs.getInt("age"));

        personList.add(person);
    }
    return personList;
 }

这个方法自由选择查询的条件,只需要向方法中传入一个条件List即可,这些条件都市有Map组成,每一个Map包含三个元素,col表示查询列,rel表示查询条件的关系,value是指查询条件的值。

PersonDao dao = new PersonDao();

List<>>  params = new ArrayList<>>();
Map  param1 = new  HashMap();
    param1.put("id", "20");
    param1.put("name", "jaerk");
    param1.put("phone", "13266512345");
    param1.put("age", "%26%");
params.add(param1);

Map  param2 = new  HashMap();
param2.put("id", "290");
    param2.put("name", "jark");
    param2.put("phone", "13666512345");
    param2.put("age", 26);
    params.add(param2);

    try {
    List personList = dao.queryParams(params);
        for (Person person : personList) {
            System.out.println(person);
    }
} catch (Exception e) {
    e.printStackTrace();
    }
    }

2增加

现在在PersonDao中写一个addPerson方法用于新增一条信息:

public void addPerson(Person person) throws Exception {
    Connection conn = DBUtil.connectDB();
    String sql = "INSERT INTO person(id, name, phone, age)" 
                   + " VALUES(?, ?, ?, ?)";

          PreparedStatement psmt = conn.prepareStatement(sql);
        psmt.setInt(1, person.getId());
    psmt.setString(2, person.getName());
    psmt.setString(3, person.getPhone());
    psmt.setInt(4, person.getAge());

    psmt.execute();
    conn.close();
}

这个方法使用conn.prepareStatement(sql)获取一个PreparedStatement对象,使用这个方法可以传入带参数的SQL语句,而参数的值可以通过PreparedStatement.setXXX(index,value)方法指定,其中xxx为各种不同的类型,index指定第几个参数,value指定了带参数的值,便可以执行excute()方法执行sql语句了。

 PersonDao dao = new PersonDao();
    Person person = new Person();

    person.setName("黑风");       
    person.setPhone("18229096642");
    person.setAge(20);
    person.setId(16);
    try {
        dao.addPerson(person);
    } catch (Exception e) {
        e.printStackTrace();
    }
    }

执行后再查看数据库,发现”黑风”用户插入成功

这里写图片描述

3:删除

接下来写一个删除的方法,根据用户的id来删除数据:

public void deleteUser(int id) throws Exception {
    Connection conn = DBUtil.connectDB();
    String sql = "DELETE FROM person WHERE id = ?";

    PreparedStatement psmt = conn.prepareStatement(sql);
    psmt.setInt(1, id);

    psmt.execute();
    }

然后写一个main方法来验证:

PersonDao dao = new PersonDao();

 try {
    dao.deleteUser(26);
    } catch (Exception e) {
        e.printStackTrace();
    }

删除id为26的用户,运行后查看数据库:

这里写图片描述

4:更新数据库

最后来看一下更新数据库:

 public void updatePerson(Person person) throws Exception {
    Connection conn = DBUtil.connectDB();
    String sql = "UPDATE person SET name=?, phone=?, age=?"
                  + " WHERE id=?";
    PreparedStatement pstmt = conn.prepareStatement(sql);
    pstmt.setInt(4, person.getId());
    pstmt.setString(1, person.getName());
    pstmt.setString(2, person.getPhone());
    pstmt.setInt(3, person.getAge());
    pstmt.executeUpdate();
    conn.close();
}

从SQL语句中可以看出更新的也就是根据用户id进行选择性的更新。
写一个main方法验证:

 PersonDao dao = new PersonDao();
 Person person = new Person();


    person.setName("黑风");       
    person.setPhone("18229096642");
    person.setAge(26);
    person.setId(18);
try {
        dao.updatePerson(person);
    } catch (Exception e) {
        e.printStackTrace();
    }
}

这个方法里将用户名为黑风的用户年龄改为26岁,执行程序,运行后查看数据库:

这里写图片描述

可以看到用户的年龄变成了26,更新成功。

三,总结
使用JDBC连接Mysql数据库并进行基本的增删改查就已经完成了,这些只是最简单的数据库操作,实际开发过程中操作数据库比这些复杂多了,包括事务处理,存储过程等等,就需要使用JDBC更高级的功能了。

相关TAG标签
上一篇:CentOS6.9+Mysql5.7.18源码安装
下一篇:数据库连接出现乱码问题
相关文章
图文推荐

关于我们 | 联系我们 | 广告服务 | 投资合作 | 版权申明 | 在线帮助 | 网站地图 | 作品发布 | Vip技术培训 | 举报中心

版权所有: 红黑联盟--致力于做实用的IT技术学习网站