数据库和表设计
-- 创建数据库
CREATE DATABASE `bank`;
-- 切换到 bank 库
USE `bank`;
-- 创建表
CREATE TABLE `user_balance` (
`id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT ,
`name` VARCHAR(45) NOT NULL ,
`balance` BIGINT NOT NULL ,
PRIMARY KEY (`id`)
)
ENGINE = InnoDB
DEFAULT CHARACTER SET = utf8mb4
COLLATE = utf8mb4_general_ci;
在 user_balance
表中准备两条数据:
mysql> select * from user_balance;
+----+--------+---------+
| id | name | balance |
+----+--------+---------+
| 1 | letian | 1000 |
| 2 | xiaosi | 1001 |
+----+--------+---------+
2 rows in set (0.00 sec)
JDBC PreparedStatement 查询数据
下面示例中的 select 方法根据name查询用户信息。
package demo;
import java.sql.*;
public class PreparedStatementSelect {
private static final String USER = "root";
private static final String PASSWORD = "123456";
private static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
private static final String DB_URL = "jdbc:mysql://127.0.0.1:3306/bank";
public static void select(String name) throws ClassNotFoundException, SQLException {
Class.forName(JDBC_DRIVER);
Connection conn = DriverManager.getConnection(DB_URL, USER, PASSWORD);
PreparedStatement pstmt = null;
try {
pstmt = conn.prepareStatement("SELECT * FROM user_balance WHERE name=?");
pstmt.setString(1, name);
ResultSet resultSet = pstmt.executeQuery();
while (resultSet.next()) {
System.out.printf("id: %s, name: %s, balance: %s\n",
resultSet.getLong("id"),
resultSet.getString("name"),
resultSet.getLong("balance"));
}
resultSet.close();
} finally {
if (pstmt != null) {
pstmt.close();
}
conn.close();
}
}
public static void main(String[] args) throws SQLException, ClassNotFoundException {
select("letian");
select("xiaosi");
}
}
执行结果:
id: 1, name: letian, balance: 1000
id: 2, name: xiaosi, balance: 1001