正文

掌握Java连接Derby数据库的5个简单步骤，轻松实现数据交互

/0 浏览量
0517

在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数据库，并实现数据的增删改查了。记住，在实际应用中，你需要处理好异常和资源管理，确保数据库连接的安全和稳定。

-- 展开阅读全文 --