Hologres:PostgreSQL SERIAL

このトピックでは、SERIAL データ型の自動インクリメントフィールドを使用例として使用します。次の SQL ステートメント例は、テーブルで SERIAL データ型を使用して colname という名前の自動インクリメントフィールドを作成する方法を示しています。サンプルステートメントの構文は、BIGSERIAL データ型にも適用されます。

CREATE TABLE tablename (
    colname serial
);

次の SQL ステートメント例は、SERIAL データ型を使用して自動インクリメントフィールドを作成する方法を示しています。サンプル SQL ステートメントの構文は、BIGSERIAL データ型にも適用されます。

// id フィールドと f1 フィールドを含むテーブルを作成します。
create table if not exists test_tb(id serial primary key, f1 text);

// INSERT ステートメントを実行して、f1 フィールドにデータを挿入します。
insert into test_tb(f1) values('1');
insert into test_tb(f1) values('2');
insert into test_tb(f1) values('3');

// test_tb テーブルのデータをクエリし、id フィールドで昇順にデータをソートします。
select * from test_tb order by id asc;

次の SQL ステートメント例は、Java Database Connectivity（JDBC）経由で Hologres に接続し、SERIAL データ型を使用して自動インクリメントフィールドを作成する方法を示しています。サンプル SQL ステートメントの構文は、BIGSERIAL データ型にも適用されます。

package test;

import java.sql.*;

public class HoloSerial {

// id フィールドと f1 フィールドを含むテーブルを作成します。
    private static void Init(Connection conn) throws Exception {
        try (Statement stmt = conn.createStatement()) {
            stmt.execute("drop table if exists test_tb;");
            stmt.execute("create table if not exists test_tb(id serial primary key, f1 text);");
        }
    }

// f1 フィールドにデータを挿入します。
    private static void TestSerial(Connection conn) throws Exception {
        try (PreparedStatement stmt = conn.prepareStatement("insert into test_tb(f1) values(?)")) {
            for (int i = 0; i < 100; ++i) {
                stmt.setString(1, String.valueOf(i + 1));
                int affected_rows = stmt.executeUpdate();
                System.out.println("affected rows => " + affected_rows);
            }
        }

// test_tb テーブルのデータをクエリし、id フィールドで昇順にデータをソートします。
        try (PreparedStatement stmt = conn.prepareStatement("select * from test_tb order by id asc")) {
            try(ResultSet rs = stmt.executeQuery()) {
                while(rs.next()) {
                    String res = rs.getObject(1).toString() + "\t" + rs.getObject(2).toString();
                    System.out.println(res);
                }
            }
        }
    }

// JDBC 経由で Hologres に接続します。
    public static void main(String[] args) throws Exception {
        Class.forName("org.postgresql.Driver").newInstance();
        String host = "127.0.0.1:13737";
        String db = "postgres";
        String user = "xx";
        String password = "xx";
        String url = "jdbc:postgresql://" + host + "/" + db;
        try (Connection conn = DriverManager.getConnection(url, user, password)) {
            Init(conn);

            TestSerial(conn);
        }
    }
}