Java – SQLiteのデータベースを作成する方法

<dependency>
    <groupId>org.xerial.sqlite-jdbc</groupId>
    <artifactId>sqlite-jdbc</artifactId>
    <version>3.36.0.3</version>
</dependency>

implementation 'org.xerial.sqlite-jdbc:sqlite-jdbc:3.36.0.3'

import java.sql.Connection; // JDBC接続用
import java.sql.DriverManager; // ドライバマネージャ
import java.sql.SQLException; // SQL例外
import java.sql.Statement; // SQL文の実行
public class App {
    public static void main(String[] args) {
        // データベースのURL
        String url = "jdbc:sqlite:sample.db"; // sample.dbという名前のデータベースを作成
        // データベース接続
        try (Connection conn = DriverManager.getConnection(url)) {
            if (conn != null) {
                // ステートメントを作成
                Statement stmt = conn.createStatement();
                // テーブルを作成するSQL文
                String sql = "CREATE TABLE IF NOT EXISTS users (" +
                             "id INTEGER PRIMARY KEY AUTOINCREMENT," +
                             "name TEXT NOT NULL," +
                             "email TEXT NOT NULL UNIQUE" +
                             ");";
                // SQL文を実行
                stmt.execute(sql); // テーブル作成を実行
                System.out.println("データベースとテーブルが作成されました。"); // 成功メッセージ
            }
        } catch (SQLException e) {
            System.out.println(e.getMessage()); // エラーメッセージを表示
        }
    }
}

データベースとテーブルが作成されました。

CREATE TABLE テーブル名 (
    カラム名1 データ型 制約,
    カラム名2 データ型 制約,
    ...
);

import java.sql.Connection; // JDBC接続用
import java.sql.DriverManager; // ドライバマネージャ
import java.sql.SQLException; // SQL例外
import java.sql.Statement; // SQL文の実行
public class App {
    public static void main(String[] args) {
        // データベースのURL
        String url = "jdbc:sqlite:sample.db"; // 既存のsample.dbを使用
        // データベース接続
        try (Connection conn = DriverManager.getConnection(url)) {
            if (conn != null) {
                // ステートメントを作成
                Statement stmt = conn.createStatement();
                // テーブルを作成するSQL文
                String sql = "CREATE TABLE IF NOT EXISTS products (" +
                             "id INTEGER PRIMARY KEY AUTOINCREMENT," +
                             "name TEXT NOT NULL," +
                             "price REAL NOT NULL" +
                             ");";
                // SQL文を実行
                stmt.execute(sql); // テーブル作成を実行
                System.out.println("テーブル 'products' が作成されました。"); // 成功メッセージ
            }
        } catch (SQLException e) {
            System.out.println(e.getMessage()); // エラーメッセージを表示
        }
    }
}

テーブル 'products' が作成されました。

try (Connection conn = DriverManager.getConnection(url)) {
    // データベース操作
} catch (SQLException e) {
    // エラーハンドリング
}

try (Connection conn = DriverManager.getConnection(url)) {
    conn.setAutoCommit(false); // 自動コミットを無効にする
    // データベース操作
    conn.commit(); // コミット
} catch (SQLException e) {
    conn.rollback(); // ロールバック
}

String sql = "INSERT INTO users(name, email) VALUES(?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
    pstmt.setString(1, "山田太郎"); // 名前を設定
    pstmt.setString(2, "taro@example.com"); // メールを設定
    pstmt.executeUpdate(); // 実行
}

try {
    // データベース操作
} catch (SQLException e) {
    System.err.println("エラーが発生しました: " + e.getMessage()); // エラーメッセージを表示
}

import java.sql.Connection; // JDBC接続用
import java.sql.DriverManager; // ドライバマネージャ
import java.sql.PreparedStatement; // プレースホルダを使用したSQL文
import java.sql.ResultSet; // 結果セット
import java.sql.SQLException; // SQL例外
import java.sql.Statement; // SQL文の実行
public class App {
    private static final String URL = "jdbc:sqlite:user_management.db"; // データベースのURL
    public static void main(String[] args) {
        createTable(); // テーブルを作成
        addUser("山田太郎", "taro@example.com"); // ユーザーを追加
        displayUsers(); // ユーザーを表示
        deleteUser(1); // IDが1のユーザーを削除
    }
    // テーブルを作成するメソッド
    private static void createTable() {
        String sql = "CREATE TABLE IF NOT EXISTS users (" +
                     "id INTEGER PRIMARY KEY AUTOINCREMENT," +
                     "name TEXT NOT NULL," +
                     "email TEXT NOT NULL UNIQUE" +
                     ");";
        try (Connection conn = DriverManager.getConnection(URL);
             Statement stmt = conn.createStatement()) {
            stmt.execute(sql); // テーブル作成を実行
            System.out.println("テーブル 'users' が作成されました。"); // 成功メッセージ
        } catch (SQLException e) {
            System.out.println(e.getMessage()); // エラーメッセージを表示
        }
    }
    // ユーザーを追加するメソッド
    private static void addUser(String name, String email) {
        String sql = "INSERT INTO users(name, email) VALUES(?, ?)";
        try (Connection conn = DriverManager.getConnection(URL);
             PreparedStatement pstmt = conn.prepareStatement(sql)) {
            pstmt.setString(1, name); // 名前を設定
            pstmt.setString(2, email); // メールを設定
            pstmt.executeUpdate(); // 実行
            System.out.println("ユーザー '" + name + "' が追加されました。"); // 成功メッセージ
        } catch (SQLException e) {
            System.out.println(e.getMessage()); // エラーメッセージを表示
        }
    }
    // ユーザーを表示するメソッド
    private static void displayUsers() {
        String sql = "SELECT * FROM users";
        try (Connection conn = DriverManager.getConnection(URL);
             Statement stmt = conn.createStatement();
             ResultSet rs = stmt.executeQuery(sql)) {
            System.out.println("ユーザー一覧: ");
            while (rs.next()) {
                System.out.println("ID: " + rs.getInt("id") + ", 名前: " + rs.getString("name") + ", メール: " + rs.getString("email"));
            }
        } catch (SQLException e) {
            System.out.println(e.getMessage()); // エラーメッセージを表示
        }
    }
    // ユーザーを削除するメソッド
    private static void deleteUser(int id) {
        String sql = "DELETE FROM users WHERE id = ?";
        try (Connection conn = DriverManager.getConnection(URL);
             PreparedStatement pstmt = conn.prepareStatement(sql)) {
            pstmt.setInt(1, id); // IDを設定
            pstmt.executeUpdate(); // 実行
            System.out.println("IDが " + id + " のユーザーが削除されました。"); // 成功メッセージ
        } catch (SQLException e) {
            System.out.println(e.getMessage()); // エラーメッセージを表示
        }
    }
}

テーブル 'users' が作成されました。
ユーザー '山田太郎' が追加されました。
ユーザー一覧: 
ID: 1, 名前: 山田太郎, メール: taro@example.com
IDが 1 のユーザーが削除されました。