使用JDBC应用程序创建新数据库需要以下步骤:
mysql-connector-java-5.1.46.jar
。
DriverManager.getConnection()
方法来创建一个Connection
对象,它表示与数据库服务器的物理连接。要创建一个新的数据库,不需要在准备数据库URL时提供任何数据库名称,如下面的示例所述。
Statement
的对象来构建和提交SQL语句到数据库。
在执行以下示例之前,请确保您已经准备好以下操作:
用户名(username)和密码(password)
。
CREATE DATABASE 01jdbc;
CREATE TABLE `user` (
`user_id` int(11) NOT NULL AUTO_INCREMENT,
`user_name` varchar(255) DEFAULT NULL,
`user_password` varchar(255) DEFAULT NULL,
PRIMARY KEY (`user_id`)
);
import java.sql.Connection;
import java.sql.DriverManager;
public class CreateData {
private static String url = "jdbc:mysql://localhost:3306/01jdbc"; // 数据库地址
private static String userName = "root"; // 数据库用户名
private static String passWord = "123456"; // 数据库密码
private static Connection conn = null;
// 获得数据库连接
public static Connection getConnection() {
if (null == conn) {
try {
Class.forName("com.mysql.jdbc.Driver"); // 加载驱动
conn = DriverManager.getConnection(url, userName, passWord); // 创建数据库连接
} catch (Exception e) {
e.printStackTrace();
System.out.println("JDBC 连接数据库失败");
}
}
return conn;
}
public static void main(String[] args) {
System.out.println("JDBC 连接数据库成功");
System.out.println("JDBC 连接地址为:" + getConnection());
}
}
JDBC 连接数据库成功
JDBC 连接地址为:com.mysql.jdbc.JDBC4Connection@67424e82
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class InsertData {
private static String url = "jdbc:mysql://localhost:3306/01jdbc"; // 数据库地址
private static String userName = "root"; // 数据库用户名
private static String passWord = "123456"; // 数据库密码
private static Connection conn = null;
public static Connection getConnection() {
if (null == conn) {
try {
// 加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 创建数据库连接
conn = DriverManager.getConnection(url, userName, passWord);
} catch (Exception e) {
e.printStackTrace();
}
}
return conn;
}
public static void main(String[] args) {
// 准备sql
String sql = "INSERT INTO user(user_name, user_password) VALUES ('兮动人1', '123456')";
Connection conn = getConnection();
PreparedStatement pst = null;
try {
// 创建预编译语句
pst = conn.prepareStatement(sql);
// 执行SQL
pst.executeUpdate();
System.out.println("JDBC 插入成功");
// 关闭资源
pst.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
System.out.println("JDBC 插入失败");
}
}
}
JDBC 插入成功
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class UpdateData {
private static String url = "jdbc:mysql://localhost:3306/01jdbc"; // 数据库地址
private static String userName = "root"; // 数据库用户名
private static String passWord = "123456"; // 数据库密码
private static Connection conn = null;
public static Connection getConnection() {
if (null == conn) {
try {
// 加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 创建数据库连接
conn = DriverManager.getConnection(url, userName, passWord);
} catch (Exception e) {
e.printStackTrace();
}
}
return conn;
}
public static void main(String[] args) {
// 准备sql
String sql = "update user set user_name='兮动人2', user_password='654321' where user_id=1";
Connection conn = getConnection();
PreparedStatement pst = null;
try {
// 创建预编译语句
pst = conn.prepareStatement(sql);
// 执行SQL
pst.executeUpdate();
System.out.println("JDBC 更新成功");
// 关闭资源
pst.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
System.out.println("JDBC 更新失败");
}
}
}
JDBC 更新成功
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class SelectData {
private static String url = "jdbc:mysql://localhost:3306/01jdbc"; // 数据库地址
private static String userName = "root"; // 数据库用户名
private static String passWord = "123456"; // 数据库密码
private static Connection conn = null;
public static Connection getConnection() {
if (null == conn) {
try {
// 加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 创建数据库连接
conn = DriverManager.getConnection(url, userName, passWord);
} catch (Exception e) {
e.printStackTrace();
}
}
return conn;
}
public static void main(String[] args) {
// 准备sql
String sql = "select * from user";
Connection conn = getConnection();
PreparedStatement pst = null;
try {
// 创建预编译语句
pst = conn.prepareStatement(sql);
// 执行SQL
ResultSet rst = pst.executeQuery();
while (rst.next()) {
System.out.print(rst.getInt("user_id"));
System.out.print(rst.getString("user_name"));
System.out.println(rst.getString("user_password"));
}
System.out.println("JDBC 查询成功");
// 关闭资源
pst.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
System.out.println("JDBC 查询失败");
}
}
}
1兮动人2 654321
2兮动人3 123
JDBC 查询成功
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class SelectByIdData {
private static String url = "jdbc:mysql://localhost:3306/01jdbc"; // 数据库地址
private static String userName = "root"; // 数据库用户名
private static String passWord = "123456"; // 数据库密码
private static Connection conn = null;
public static Connection getConnection() {
if (null == conn) {
try {
// 加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 创建数据库连接
conn = DriverManager.getConnection(url, userName, passWord);
} catch (Exception e) {
e.printStackTrace();
}
}
return conn;
}
public static void main(String[] args) {
// 准备sql
String sql = "select * from user where user_id = 1";
Connection conn = getConnection();
PreparedStatement pst = null;
try {
// 创建预编译语句
pst = conn.prepareStatement(sql);
// 执行SQL
ResultSet rst = pst.executeQuery();
while (rst.next()) {
System.out.print(rst.getInt("user_id"));
System.out.print(rst.getString("user_name"));
System.out.println(rst.getString("user_password"));
}
System.out.println("JDBC 条件查询成功");
// 关闭资源
pst.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
System.out.println("JDBC 条件查询失败");
}
}
}
1兮动人2 654321
JDBC 条件查询成功
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class DeleteDate {
private static String url = "jdbc:mysql://localhost:3306/easilyj"; // 数据库地址
private static String userName = "root"; // 数据库用户名
private static String passWord = "123456"; // 数据库密码
private static Connection conn = null;
public static Connection getConnection() {
if (null == conn) {
try {
// 加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 创建数据库连接
conn = DriverManager.getConnection(url, userName, passWord);
} catch (Exception e) {
e.printStackTrace();
}
}
return conn;
}
public static void main(String[] args) {
// 准备sql
String sql = "delete from user where user_id = 2";
Connection conn = getConnection();
PreparedStatement pst = null;
try {
// 创建预编译语句
pst = conn.prepareStatement(sql);
// 执行SQL
pst.executeUpdate();
System.out.println("JDBC 删除成功");
// 关闭资源
pst.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
System.out.println("JDBC 删除失败");
}
}
}
JDBC 删除成功
import java.sql.Connection;
import java.sql.DriverManager;
public class DBUtil {
private static String url = "jdbc:mysql://localhost:3306/01jdbc"; // 数据库地址
private static String userName = "root"; // 数据库用户名
private static String passWord = "123456"; // 数据库密码
private static Connection conn = null;
public static Connection getConnection() {
if (null == conn) {
try {
// 加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 创建数据库连接
conn = DriverManager.getConnection(url, userName, passWord);
} catch (Exception e) {
e.printStackTrace();
}
}
return conn;
}
public static void main(String[] args) {
// 测试数据库是否连通
System.out.println(getConnection());
}
}
com.mysql.jdbc.JDBC4Connection@67424e82
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import com.xdr.util.DBUtil;
public class InsertData {
public static void main(String[] args) {
// 准备sql
String sql = "INSERT INTO user(user_name, user_password) VALUES ('雲兮动人', '123456')";
Connection conn = DBUtil.getConnection();
PreparedStatement pst = null;
try {
// 创建预编译语句
pst = conn.prepareStatement(sql);
// 执行SQL
pst.executeUpdate();
System.out.println("JDBC 插入成功");
// 关闭资源
pst.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
System.out.println("JDBC 插入失败");
}
}
}