org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl クラス

org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl の継承関係図

org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl 連携図

公開メンバ関数
	SqlPersistenceServiceImpl (SqlPersistenceProvider provider)
void	create ()
boolean	create (Rp rp)
boolean	update (Rp rp)
Rp	getRp (String oxdId)
boolean	removeAllRps ()
Set< Rp >	getRps ()
void	destroy ()
boolean	remove (String oxdId)

静的公開メンバ関数
static void	rollbackSilently (Connection conn)

非公開メンバ関数
void	createSchema ()

非公開変数類
SqlPersistenceProvider	provider

静的非公開変数類
static final Logger	LOG = LoggerFactory.getLogger(SqlPersistenceServiceImpl.class)

詳解

著者

yuriyz

構築子と解体子

SqlPersistenceServiceImpl()

org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.SqlPersistenceServiceImpl ( SqlPersistenceProvider  provider )

inline

                                                                      {
        this.provider = provider;
    }

関数詳解

create() [1/2]

void org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.create ( )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                         {
        provider.onCreate();

        createSchema();
    }

create() [2/2]

boolean org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.create ( Rp  rp )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                                 {
        Connection conn = null;
        try {
            conn = provider.getConnection();
            conn.setAutoCommit(false);
            PreparedStatement query = conn.prepareStatement("insert into rp(id, data) values(?, ?)");
            query.setString(1, rp.getOxdId());
            query.setString(2, Jackson.asJson(rp));
            query.executeUpdate();
            query.close();

            conn.commit();
            LOG.debug("RP created successfully. RP : " + rp);
            return true;
        } catch (Exception e) {
            LOG.error("Failed to create RP: " + rp, e);
            rollbackSilently(conn);
            return false;
        } finally {
            IOUtils.closeSilently(conn);
        }
    }

createSchema()

void org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.createSchema ( )

inlineprivate

                                {
        Connection conn = null;
        try {
            conn = provider.getConnection();
            conn.setAutoCommit(false);

            PreparedStatement createRpTable = conn.prepareStatement(
                    "create table if not exists rp(id varchar(36) primary key, data varchar(65534))");
            createRpTable.executeUpdate();
            createRpTable.close();

            conn.commit();
            LOG.debug("Schema created successfully.");
        } catch (Exception e) {
            LOG.error("Failed to create schema. Error: " + e.getMessage(), e);
            rollbackSilently(conn);
            throw new RuntimeException(e);
        } finally {
            IOUtils.closeSilently(conn);
        }
    }

destroy()

void org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.destroy ( )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                          {
        provider.onDestroy();
    }

getRp()

Rp org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.getRp ( String  oxdId )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                                  {
        Connection conn = null;
        try {
            conn = provider.getConnection();
            conn.setAutoCommit(false);

            PreparedStatement query = conn.prepareStatement("select id, data from rp where id = ?");
            query.setString(1, oxdId);
            ResultSet rs = query.executeQuery();

            rs.next();
            String data = rs.getString("data");
            query.close();
            conn.commit();

            Rp rp = MigrationService.parseRp(data);
            if (rp != null) {
                LOG.debug("Found RP id: " + oxdId + ", RP : " + rp);
                return rp;
            } else {
                LOG.error("Failed to fetch RP by id: " + oxdId);
                return null;
            }
        } catch (Exception e) {
            LOG.error("Failed to find RP by id: " + oxdId + ". Error: " + e.getMessage(), e);
            rollbackSilently(conn);
            return null;
        } finally {
            IOUtils.closeSilently(conn);
        }
    }

getRps()

Set<Rp> org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.getRps ( )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                            {
        Connection conn = null;
        try {
            conn = provider.getConnection();
            conn.setAutoCommit(false);

            PreparedStatement query = conn.prepareStatement("select id, data from rp");
            ResultSet rs = query.executeQuery();

            Set<Rp> result = new HashSet<>();
            while (rs.next()) {
                String id = rs.getString("id");
                String data = rs.getString("data");

                Rp rp = MigrationService.parseRp(data);
                if (rp != null) {
                    result.add(rp);
                } else {
                    LOG.error("Failed to parse rp, id: " + id);
                }
            }

            query.close();
            conn.commit();
            LOG.info("Loaded " + result.size() + " RPs.");
            return result;
        } catch (Exception e) {
            LOG.error("Failed to fetch rps. Error: " + e.getMessage(), e);
            rollbackSilently(conn);
            throw new RuntimeException(e);
        } finally {
            IOUtils.closeSilently(conn);
        }
    }

remove()

boolean org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.remove ( String  oxdId )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                                        {
        Connection conn = null;
        try {
            conn = provider.getConnection();
            conn.setAutoCommit(false);

            PreparedStatement query = conn.prepareStatement("delete from rp where id = ?");
            query.setString(1, oxdId);
            query.executeUpdate();
            query.close();

            conn.commit();
            LOG.debug("Removed rp successfully. oxdId: " + oxdId);
            return true;
        } catch (Exception e) {
            LOG.error("Failed to remove rp with oxdId: " + oxdId, e);
            rollbackSilently(conn);
            return false;
        } finally {
            IOUtils.closeSilently(conn);
        }
    }

removeAllRps()

boolean org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.removeAllRps ( )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                                  {
        Connection conn = null;
        try {
            conn = provider.getConnection();
            conn.setAutoCommit(false);
            PreparedStatement query = conn.prepareStatement("delete from rp");
            query.executeUpdate();
            query.close();

            conn.commit();
            LOG.debug("All RPs are removed successfully.");
            return true;
        } catch (Exception e) {
            LOG.error("Failed to drop all RPs", e);
            rollbackSilently(conn);
            return false;
        } finally {
            IOUtils.closeSilently(conn);
        }
    }

rollbackSilently()

static void org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.rollbackSilently ( Connection  conn )

inlinestatic

                                                         {
        try {
            conn.rollback();
        } catch (SQLException e) {
            LOG.error("Failed to rollback transaction, error: " + e.getMessage(), e);
        }
    }

update()

boolean org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.update ( Rp  rp )

inline

org.xdi.oxd.server.persistence.PersistenceServiceを実装しています。

                                 {
        Connection conn = null;
        try {
            conn = provider.getConnection();
            conn.setAutoCommit(false);
            PreparedStatement query = conn.prepareStatement("update rp set data = ? where id = ?");
            query.setString(1, Jackson.asJson(rp));
            query.setString(2, rp.getOxdId());
            query.executeUpdate();
            query.close();

            conn.commit();
            LOG.debug("RP updated successfully. RP : " + rp);
            return true;
        } catch (Exception e) {
            LOG.error("Failed to update RP: " + rp, e);
            rollbackSilently(conn);
            return false;
        } finally {
            IOUtils.closeSilently(conn);
        }
    }

メンバ詳解

LOG

final Logger org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.LOG = LoggerFactory.getLogger(SqlPersistenceServiceImpl.class)

staticprivate

provider

SqlPersistenceProvider org.xdi.oxd.server.persistence.SqlPersistenceServiceImpl.provider

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/OpenId/gluu/src/oxd/oxd-server/src/main/java/org/xdi/oxd/server/persistence/SqlPersistenceServiceImpl.java