在Java编程中,连接数据库是进行数据交互的基础。Derby是一个开源的、纯Java的数据库,非常适合于嵌入式应用。下面,我将带你一步步掌握如何使用Java连接Derby数据库,实现数据的增删改查。
步骤1:添加Derby数据库的依赖
首先,你需要确保你的Java项目中包含了Derby数据库的JAR文件。你可以在Apache Derby的官方网站上下载最新版本的Derby数据库JAR文件。
<!-- 在你的pom.xml文件中添加以下依赖 -->
<dependency>
<groupId>org.apache.derby</groupId>
<artifactId>derby</artifactId>
<version>10.15.2.0</version>
</dependency>
步骤2:创建数据库连接
使用Java的java.sql.Connection类来创建与Derby数据库的连接。你需要提供数据库的URL、用户名和密码。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DerbyConnection {
public static void main(String[] args) {
String dbURL = "jdbc:derby://localhost:1527/myDB;create=true";
String user = "user";
String password = "password";
try (Connection conn = DriverManager.getConnection(dbURL, user, password)) {
System.out.println("Connected to the database successfully!");
} catch (SQLException e) {
e.printStackTrace();
}
}
}
步骤3:创建数据库表
在连接到数据库后,你可以使用SQL语句来创建表。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class CreateTable {
public static void main(String[] args) {
String dbURL = "jdbc:derby://localhost:1527/myDB;create=true";
String user = "user";
String password = "password";
try (Connection conn = DriverManager.getConnection(dbURL, user, password);
Statement stmt = conn.createStatement()) {
String sql = "CREATE TABLE Employees (" +
"id INT NOT NULL," +
"name VARCHAR(100)," +
"age INT)";
stmt.executeUpdate(sql);
System.out.println("Table created successfully!");
} catch (SQLException e) {
e.printStackTrace();
}
}
}
步骤4:插入数据
创建表之后,你可以插入数据到表中。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class InsertData {
public static void main(String[] args) {
String dbURL = "jdbc:derby://localhost:1527/myDB";
String user = "user";
String password = "password";
String sql = "INSERT INTO Employees (id, name, age) VALUES (?, ?, ?)";
try (Connection conn = DriverManager.getConnection(dbURL, user, password);
PreparedStatement pstmt = conn.prepareStatement(sql)) {
pstmt.setInt(1, 1);
pstmt.setString(2, "John Doe");
pstmt.setInt(3, 30);
pstmt.executeUpdate();
System.out.println("Data inserted successfully!");
} catch (SQLException e) {
e.printStackTrace();
}
}
}
步骤5:查询数据
最后,你可以查询刚刚插入的数据。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class QueryData {
public static void main(String[] args) {
String dbURL = "jdbc:derby://localhost:1527/myDB";
String user = "user";
String password = "password";
String sql = "SELECT * FROM Employees WHERE id = ?";
try (Connection conn = DriverManager.getConnection(dbURL, user, password);
PreparedStatement pstmt = conn.prepareStatement(sql)) {
pstmt.setInt(1, 1);
ResultSet rs = pstmt.executeQuery();
while (rs.next()) {
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age);
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
通过以上五个简单的步骤,你就可以在Java中连接Derby数据库,并实现数据的增删改查了。记住,在实际应用中,你需要处理好异常和资源管理,确保数据库连接的安全和稳定。
