Author: prabath
Date: Fri Feb 8 02:45:28 2008
New Revision: 13460
Log:
dao over openid_user_rp
Added:
trunk/solutions/identity/modules/identity-provider/src/main/java/org/wso2/solutions/identity/persistence/dao/OpenIDUserRPDAO.java
Added:
trunk/solutions/identity/modules/identity-provider/src/main/java/org/wso2/solutions/identity/persistence/dao/OpenIDUserRPDAO.java
==============================================================================
--- (empty file)
+++
trunk/solutions/identity/modules/identity-provider/src/main/java/org/wso2/solutions/identity/persistence/dao/OpenIDUserRPDAO.java
Fri Feb 8 02:45:28 2008
@@ -0,0 +1,44 @@
+package org.wso2.solutions.identity.persistence.dao;
+
+import java.util.List;
+
+import org.hibernate.Query;
+import org.hibernate.Session;
+import org.hibernate.Transaction;
+import org.wso2.solutions.identity.persistence.dataobject.OpenIDUserRPDO;
+
+public class OpenIDUserRPDAO extends BaseDAO {
+
+ public OpenIDUserRPDAO(
+ org.wso2.solutions.identity.persistence.HibernateConfig config) {
+ super(config);
+ // TODO Auto-generated constructor stub
+ }
+
+ public OpenIDUserRPDO[] getOpenIDUserRP(String userId, String rpUrl) {
+
+ Session session = hbConfig.getCurrentSession();
+ Transaction tx = session.beginTransaction();
+ String stmt = "from OpenIDUserRPDO as c where c.rpUrl = '" + rpUrl
+ + "' and c.userId='" + userId + "'";
+
+ OpenIDUserRPDO[] rpdo = new OpenIDUserRPDO[0];
+
+ try {
+ Query query = session.createQuery(stmt);
+ List lst = query.list();
+ rpdo = (OpenIDUserRPDO[]) lst
+ .toArray(new OpenIDUserRPDO[lst.size()]);
+ tx.commit();
+ } catch (Throwable e) {
+ tx.rollback();
+ String msg = messages.getMessage("errorQuerryingClaimData");
+ throw new RuntimeException(msg, e);
+ } finally {
+ hbConfig.closeSession();
+ }
+
+ return rpdo;
+ }
+
+}
_______________________________________________
Identity-dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/identity-dev
