JAVA中连接mysql数据库

上周做了数据库的课程设计，用的是java语言和mysql数据库，其中就涉及java连接数据库的相关知识。

1. 首先我们需要添加一个jar文件，就相当于连接的一个驱动文件，这里我添加的是这个文件：mysql-connector-java-5.1.13-bin.jar
2. 然后我们就可以进行数据库的连接了，在java里面进行一些数据库中的操作：增，删，改，查；
3. 然后在java中创建一个user类，在mysql中创建一个user表：

package entity;

public class user {
    private int id;
    private String user;
    private String pwd;
    private String mark;

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getUser() {
        return user;
    }

    public void setUser(String user) {
        this.user = user;
    }

    public String getPwd() {
        return pwd;
    }

    public void setPwd(String pwd) {
        this.pwd = pwd;
    }

    public String getMark() {
        return mark;
    }

    public void setMark(String mark) {
        this.mark = mark;
    }

}

1. 然后我们就可以在java中进行一些数据库中的操作啦：
   增：删除和更新操作和增加差不多，就改一下数据库中的语句就行啦。

public int addUser(user u) {
        List<user> list = new ArrayList<user>();
        Connection ct = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        int result = 0;
        try {
            Statement sta = null;
            Class.forName("com.mysql.jdbc.Driver");
            ct = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/whj","root", "");//连接数据库
            String sql = "insert into user(user,pwd,mark) values(‘"+u.getUser()+"‘,‘"+u.getPwd()+"‘,‘"+u.getMark()+"‘)";//插入新用户
            sta = ct.createStatement();
            result = sta.executeUpdate(sql);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return result;
    }

查询：

public int getUser(user u) {
        List<user> list = new ArrayList<user>();
        Connection ct = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            Statement sta = null;
            Class.forName("com.mysql.jdbc.Driver");//加载驱动
            ct = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/whj",
                    "root", "");//连接数据库
            String sql = "select * from user";//查询所有的用户
            ps = (PreparedStatement) ct.prepareStatement(sql);
            rs = ps.executeQuery();
            while (rs.next()) {
                user use = new user();
                use.setId(rs.getInt("id"));
                use.setUser(rs.getString("user"));
                use.setPwd(rs.getString("pwd"));
                use.setMark(rs.getString("mark"));
                list.add(use);
            }
            for (int i = 0; i < list.size(); i++) {
                user use = list.get(i);
                if (use.getUser().equals(u.getUser())//进行验证判断
                        && use.getPwd().equals(u.getPwd())) {
                    return 0;
                }
                if (i == list.size() - 1) {
                    return -1;
                }
            }
            ct.close();

        } catch (Exception e) {
            e.printStackTrace();
        }
        return -1;
    }

然后这就是java中的连接数据库的一些基本操作。