【Java】仿真qq尝试：用户注册（三）

需求：

实现用户名和密码存入数据库。

思路：

1、连接数据表用静态加载块

2、crud写成4个静态方法

具体流程：

from:https://www.tutorialspoint.com/jdbc/jdbc-sample-code.htm

参考：

1、jdbc：http://blog.csdn.net/williamchew/article/details/51951551

2、jdbc：http://www.cnblogs.com/wuyuegb2312/p/3872607.html

3、mysql:Mysql数据库中怎样快速查询符合条件的记录是否存在

4、select 1 的含义：https://zhidao.baidu.com/question/940814605173482052.html

5、判断resultset为空：http://bbs.csdn.net/topics/60427882

代码：

jdbc

1、intellij idea添加jar包，在Project Structure的dependencies里添加。

成功添加后external libraries是这样子的：

2、写代码前的准备--创建数据表

3、尝试

// import org.gjt.mm.mysql.*; 测试package是否正确导入

import java.sql.*;

public class Database {

}

public static void main(String[] args) {

        try {

            Class.forName("org.gjt.mm.mysql.Driver");

        } catch (ClassNotFoundException e) {

            e.printStackTrace();

        }

    }

Class是一个类，forName是这个类的一个静态方法。传入的string必须是某个类的全名，返回值为该类的对象。这里用这种方式加载驱动Driver的静态语句块。（为什么不可以用new Driver();的方式加载呢？）各种数据库对应的jar包、驱动类名和URL格式补充：静态的两个特点：静态的只会在说明类的时候执行一次；不论创建多少对象静态的只有一份。

    public static void main(String[] args) {

        try {

            Class.forName(JDBC_DRIVER);

            Connection conn = DriverManager.getConnection(DB_URL, USER, PASS); // 可以理解为IO中的定位，传入URL可以推测getConnection里一定包装了关于Socket的操作

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

可以观察到，不论是Driver或是Connection对象，都不是通过new来创建的。

// JDBC驱动名称和数据库位置

    static final String JDBC_DRIVER = "org.gjt.mm.mysql.Driver";

    static final String DB_URL = "jdbc:mysql://localhost:3306/qq";

    //  用户名和密码

    static final String USER = "root";

    static final String PASS = "pass";

    public static void main(String[] args) throws SQLException {

        Connection conn = null;

        Statement stmt = null;

        try {

            Class.forName(JDBC_DRIVER);

            conn = DriverManager.getConnection(DB_URL, USER, PASS); // 可以理解为IO中的定位，传入URL可以推测getConnection里一定包装了关于Socket的操作

            stmt = conn.createStatement();

            String sql = "insert user(username, password)values('red2', 'a123456')";

            System.out.println(stmt.executeUpdate(sql));

        } catch (Exception e) {

            e.printStackTrace();

        } finally {

            try {

                stmt.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

            try {

                conn.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

升级update部分：

prep = conn.prepareStatement("insert user(username, password) values(? , ?)");

            prep.setString(1, "hi");

            prep.setString(2, "ss");

            System.out.println(prep.executeUpdate());

融入主代码

package com.xkfx.qq.tools.serverOnly;

import com.xkfx.qq.tools.transmit.User;

import java.sql.*;

public class Database {

    private static final String JDBC_DRIVER = "org.gjt.mm.mysql.Driver";

    private static final String DB_URL = "jdbc:mysql://localhost:3306/qq";

    private static final String USER = "root";

    private static final String PASS = "pass";

    private static Connection conn = null;

    static {

        try {

            Class.forName(JDBC_DRIVER);

            conn = DriverManager.getConnection(DB_URL, USER, PASS);

        } catch (ClassNotFoundException e) {

            e.printStackTrace();

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

    public static void close() {

        try {

            conn.close();

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

    public static void saveUser(User user) {

        PreparedStatement prep = null;

        try {

            prep = conn.prepareStatement("INSERT USER(username, password) VALUES(? , ?)");

            prep.setString(1, user.getUsername());

            prep.setString(2, user.getPassword());

            prep.executeUpdate();

        } catch (SQLException e) {

            e.printStackTrace();

        } finally {

            try {

                prep.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

    public static User get(String username) {

        return null;

    }

    public static void updateUser(User user) {

    }

    public static void removeUser(User user) {

        PreparedStatement prep = null;

        try {

            prep = conn.prepareStatement("DELETE FROM USER WHERE username=?");

            prep.setString(1, user.getUsername());

            prep.execute();

        } catch (SQLException e) {

            e.printStackTrace();

        } finally {

            try {

                prep.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

    public static boolean find(String username) {

        boolean flag = false;

        PreparedStatement prep = null;

        try {

            prep = conn.prepareStatement("SELECT 1 FROM USER WHERE username=?");

            prep.setString(1, username);

            flag = prep.executeQuery().next();

        } catch (SQLException e) {

            e.printStackTrace();

        } finally {

            try {

                prep.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        return flag;

    }

}

巴特西

【Java】仿真qq尝试：用户注册（三）

最新文章

热门文章