【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;
}
}