|
@@ -0,0 +1,309 @@
|
|
|
+/* Copyright 2004 Acegi Technology Pty Limited
|
|
|
+ *
|
|
|
+ * Licensed under the Apache License, Version 2.0 (the "License");
|
|
|
+ * you may not use this file except in compliance with the License.
|
|
|
+ * You may obtain a copy of the License at
|
|
|
+ *
|
|
|
+ * http://www.apache.org/licenses/LICENSE-2.0
|
|
|
+ *
|
|
|
+ * Unless required by applicable law or agreed to in writing, software
|
|
|
+ * distributed under the License is distributed on an "AS IS" BASIS,
|
|
|
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
|
+ * See the License for the specific language governing permissions and
|
|
|
+ * limitations under the License.
|
|
|
+ */
|
|
|
+
|
|
|
+package sample.contact;
|
|
|
+
|
|
|
+import net.sf.acegisecurity.acl.basic.SimpleAclEntry;
|
|
|
+
|
|
|
+import org.springframework.jdbc.core.SqlParameter;
|
|
|
+import org.springframework.jdbc.core.support.JdbcDaoSupport;
|
|
|
+import org.springframework.jdbc.object.MappingSqlQuery;
|
|
|
+import org.springframework.jdbc.object.SqlUpdate;
|
|
|
+
|
|
|
+import java.sql.ResultSet;
|
|
|
+import java.sql.SQLException;
|
|
|
+import java.sql.Types;
|
|
|
+
|
|
|
+import java.util.List;
|
|
|
+
|
|
|
+import javax.sql.DataSource;
|
|
|
+
|
|
|
+
|
|
|
+/**
|
|
|
+ * Base implementation of {@link ContactDao} that uses Spring JDBC services.
|
|
|
+ *
|
|
|
+ * @author Ben Alex
|
|
|
+ * @version $Id$
|
|
|
+ */
|
|
|
+public class ContactDaoSpring extends JdbcDaoSupport implements ContactDao {
|
|
|
+ //~ Instance fields ========================================================
|
|
|
+
|
|
|
+ private AclObjectIdentityByObjectIdentityQuery aclObjectIdentityByObjectIdentityQuery;
|
|
|
+ private AclObjectIdentityInsert aclObjectIdentityInsert;
|
|
|
+ private ContactDelete contactDelete;
|
|
|
+ private ContactInsert contactInsert;
|
|
|
+ private ContactUpdate contactUpdate;
|
|
|
+ private ContactsAllQuery contactsAllQuery;
|
|
|
+ private ContactsByIdQuery contactsByIdQuery;
|
|
|
+ private PermissionDelete permissionDelete;
|
|
|
+ private PermissionInsert permissionInsert;
|
|
|
+ private PrincipalsAllQuery principalsAllQuery;
|
|
|
+ private RolesAllQuery rolesAllQuery;
|
|
|
+
|
|
|
+ //~ Methods ================================================================
|
|
|
+
|
|
|
+ public Contact getById(Integer id) {
|
|
|
+ List list = contactsByIdQuery.execute(id.intValue());
|
|
|
+
|
|
|
+ if (list.size() == 0) {
|
|
|
+ return null;
|
|
|
+ } else {
|
|
|
+ return (Contact) list.get(0);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public void create(Contact contact) {
|
|
|
+ contactInsert.insert(contact);
|
|
|
+ }
|
|
|
+
|
|
|
+ public Integer createAclObjectIdentity(Contact contact) {
|
|
|
+ return new Integer(aclObjectIdentityInsert.insert(makeObjectIdentity(
|
|
|
+ contact), null, SimpleAclEntry.class.getName()));
|
|
|
+ }
|
|
|
+
|
|
|
+ public void createPermission(Integer aclObjectIdentity, String recipient,
|
|
|
+ int permission) {
|
|
|
+ permissionInsert.insert(aclObjectIdentity, recipient,
|
|
|
+ new Integer(permission));
|
|
|
+ }
|
|
|
+
|
|
|
+ public void delete(Integer contactId) {
|
|
|
+ contactDelete.delete(contactId);
|
|
|
+ }
|
|
|
+
|
|
|
+ public void deletePermission(Integer aclObjectIdentity, String recipient) {
|
|
|
+ permissionDelete.delete(aclObjectIdentity, recipient);
|
|
|
+ }
|
|
|
+
|
|
|
+ public List findAll() {
|
|
|
+ return contactsAllQuery.execute();
|
|
|
+ }
|
|
|
+
|
|
|
+ public List findAllPrincipals() {
|
|
|
+ return principalsAllQuery.execute();
|
|
|
+ }
|
|
|
+
|
|
|
+ public List findAllRoles() {
|
|
|
+ return rolesAllQuery.execute();
|
|
|
+ }
|
|
|
+
|
|
|
+ public Integer lookupAclObjectIdentity(Contact contact) {
|
|
|
+ List list = aclObjectIdentityByObjectIdentityQuery.execute(makeObjectIdentity(
|
|
|
+ contact));
|
|
|
+
|
|
|
+ if (list.size() == 0) {
|
|
|
+ return null;
|
|
|
+ } else {
|
|
|
+ return (Integer) list.get(0);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public void update(Contact contact) {
|
|
|
+ contactUpdate.update(contact);
|
|
|
+ }
|
|
|
+
|
|
|
+ protected void initDao() throws Exception {
|
|
|
+ contactInsert = new ContactInsert(getDataSource());
|
|
|
+ contactUpdate = new ContactUpdate(getDataSource());
|
|
|
+ contactDelete = new ContactDelete(getDataSource());
|
|
|
+ aclObjectIdentityInsert = new AclObjectIdentityInsert(getDataSource());
|
|
|
+ permissionInsert = new PermissionInsert(getDataSource());
|
|
|
+ permissionDelete = new PermissionDelete(getDataSource());
|
|
|
+ contactsAllQuery = new ContactsAllQuery(getDataSource());
|
|
|
+ principalsAllQuery = new PrincipalsAllQuery(getDataSource());
|
|
|
+ rolesAllQuery = new RolesAllQuery(getDataSource());
|
|
|
+ contactsByIdQuery = new ContactsByIdQuery(getDataSource());
|
|
|
+ aclObjectIdentityByObjectIdentityQuery = new AclObjectIdentityByObjectIdentityQuery(getDataSource());
|
|
|
+ }
|
|
|
+
|
|
|
+ private String makeObjectIdentity(Contact contact) {
|
|
|
+ return contact.getClass().getName() + ":" + contact.getId();
|
|
|
+ }
|
|
|
+
|
|
|
+ //~ Inner Classes ==========================================================
|
|
|
+
|
|
|
+ protected class AclObjectIdentityByObjectIdentityQuery
|
|
|
+ extends MappingSqlQuery {
|
|
|
+ protected AclObjectIdentityByObjectIdentityQuery(DataSource ds) {
|
|
|
+ super(ds,
|
|
|
+ "SELECT id FROM acl_object_identity WHERE object_identity = ?");
|
|
|
+ declareParameter(new SqlParameter(Types.VARCHAR));
|
|
|
+ compile();
|
|
|
+ }
|
|
|
+
|
|
|
+ protected Object mapRow(ResultSet rs, int rownum)
|
|
|
+ throws SQLException {
|
|
|
+ return new Integer(rs.getInt("id"));
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ protected class AclObjectIdentityInsert extends SqlUpdate {
|
|
|
+ protected AclObjectIdentityInsert(DataSource ds) {
|
|
|
+ super(ds, "INSERT INTO acl_object_identity VALUES (?, ?, ?, ?)");
|
|
|
+ declareParameter(new SqlParameter(Types.INTEGER));
|
|
|
+ declareParameter(new SqlParameter(Types.VARCHAR));
|
|
|
+ declareParameter(new SqlParameter(Types.INTEGER));
|
|
|
+ declareParameter(new SqlParameter(Types.VARCHAR));
|
|
|
+ compile();
|
|
|
+ }
|
|
|
+
|
|
|
+ protected int insert(String objectIdentity,
|
|
|
+ Integer parentAclObjectIdentity, String aclClass) {
|
|
|
+ Object[] objs = new Object[] {null, objectIdentity, parentAclObjectIdentity, aclClass};
|
|
|
+ super.update(objs);
|
|
|
+
|
|
|
+ return getJdbcTemplate().queryForInt("call identity()");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ protected class ContactDelete extends SqlUpdate {
|
|
|
+ protected ContactDelete(DataSource ds) {
|
|
|
+ super(ds, "DELETE FROM contacts WHERE id = ?");
|
|
|
+ declareParameter(new SqlParameter(Types.INTEGER));
|
|
|
+ compile();
|
|
|
+ }
|
|
|
+
|
|
|
+ protected void delete(Integer contactId) {
|
|
|
+ super.update(contactId.intValue());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ protected class ContactInsert extends SqlUpdate {
|
|
|
+ protected ContactInsert(DataSource ds) {
|
|
|
+ super(ds, "INSERT INTO contacts VALUES (?, ?, ?)");
|
|
|
+ declareParameter(new SqlParameter(Types.INTEGER));
|
|
|
+ declareParameter(new SqlParameter(Types.VARCHAR));
|
|
|
+ declareParameter(new SqlParameter(Types.VARCHAR));
|
|
|
+ compile();
|
|
|
+ }
|
|
|
+
|
|
|
+ protected void insert(Contact contact) {
|
|
|
+ Object[] objs = new Object[] {contact.getId(), contact.getName(), contact
|
|
|
+ .getEmail()};
|
|
|
+ super.update(objs);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ protected class ContactUpdate extends SqlUpdate {
|
|
|
+ protected ContactUpdate(DataSource ds) {
|
|
|
+ super(ds,
|
|
|
+ "UPDATE contacts SET contact_name = ?, address = ? WHERE id = ?");
|
|
|
+ declareParameter(new SqlParameter(Types.VARCHAR));
|
|
|
+ declareParameter(new SqlParameter(Types.VARCHAR));
|
|
|
+ declareParameter(new SqlParameter(Types.INTEGER));
|
|
|
+ compile();
|
|
|
+ }
|
|
|
+
|
|
|
+ protected void update(Contact contact) {
|
|
|
+ Object[] objs = new Object[] {contact.getName(), contact.getEmail(), contact
|
|
|
+ .getId()};
|
|
|
+ super.update(objs);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ protected class ContactsAllQuery extends MappingSqlQuery {
|
|
|
+ protected ContactsAllQuery(DataSource ds) {
|
|
|
+ super(ds, "SELECT id, contact_name, email FROM contacts ORDER BY id");
|
|
|
+ compile();
|
|
|
+ }
|
|
|
+
|
|
|
+ protected Object mapRow(ResultSet rs, int rownum)
|
|
|
+ throws SQLException {
|
|
|
+ Contact contact = new Contact();
|
|
|
+ contact.setId(new Integer(rs.getInt("id")));
|
|
|
+ contact.setName(rs.getString("contact_name"));
|
|
|
+ contact.setEmail(rs.getString("email"));
|
|
|
+
|
|
|
+ return contact;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ protected class ContactsByIdQuery extends MappingSqlQuery {
|
|
|
+ protected ContactsByIdQuery(DataSource ds) {
|
|
|
+ super(ds,
|
|
|
+ "SELECT id, contact_name, email FROM contacts WHERE id = ? ORDER BY id");
|
|
|
+ declareParameter(new SqlParameter(Types.INTEGER));
|
|
|
+ compile();
|
|
|
+ }
|
|
|
+
|
|
|
+ protected Object mapRow(ResultSet rs, int rownum)
|
|
|
+ throws SQLException {
|
|
|
+ Contact contact = new Contact();
|
|
|
+ contact.setId(new Integer(rs.getInt("id")));
|
|
|
+ contact.setName(rs.getString("contact_name"));
|
|
|
+ contact.setEmail(rs.getString("email"));
|
|
|
+
|
|
|
+ return contact;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ protected class PermissionDelete extends SqlUpdate {
|
|
|
+ protected PermissionDelete(DataSource ds) {
|
|
|
+ super(ds,
|
|
|
+ "DELETE FROM acl_permission WHERE ACL_OBJECT_IDENTITY = ? AND RECIPIENT = ?");
|
|
|
+ declareParameter(new SqlParameter(Types.INTEGER));
|
|
|
+ declareParameter(new SqlParameter(Types.VARCHAR));
|
|
|
+ compile();
|
|
|
+ }
|
|
|
+
|
|
|
+ protected void delete(Integer aclObjectIdentity, String recipient) {
|
|
|
+ super.update(new Object[] {aclObjectIdentity, recipient});
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ protected class PermissionInsert extends SqlUpdate {
|
|
|
+ protected PermissionInsert(DataSource ds) {
|
|
|
+ super(ds, "INSERT INTO acl_permission VALUES (?, ?, ?, ?);");
|
|
|
+ declareParameter(new SqlParameter(Types.INTEGER));
|
|
|
+ declareParameter(new SqlParameter(Types.INTEGER));
|
|
|
+ declareParameter(new SqlParameter(Types.VARCHAR));
|
|
|
+ declareParameter(new SqlParameter(Types.INTEGER));
|
|
|
+ compile();
|
|
|
+ }
|
|
|
+
|
|
|
+ protected int insert(Integer aclObjectIdentity, String recipient,
|
|
|
+ Integer mask) {
|
|
|
+ Object[] objs = new Object[] {null, aclObjectIdentity, recipient, mask};
|
|
|
+ super.update(objs);
|
|
|
+
|
|
|
+ return getJdbcTemplate().queryForInt("call identity()");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ protected class PrincipalsAllQuery extends MappingSqlQuery {
|
|
|
+ protected PrincipalsAllQuery(DataSource ds) {
|
|
|
+ super(ds, "SELECT username FROM users ORDER BY username");
|
|
|
+ compile();
|
|
|
+ }
|
|
|
+
|
|
|
+ protected Object mapRow(ResultSet rs, int rownum)
|
|
|
+ throws SQLException {
|
|
|
+ return rs.getString("username");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ protected class RolesAllQuery extends MappingSqlQuery {
|
|
|
+ protected RolesAllQuery(DataSource ds) {
|
|
|
+ super(ds,
|
|
|
+ "SELECT DISTINCT authority FROM authorities ORDER BY authority");
|
|
|
+ compile();
|
|
|
+ }
|
|
|
+
|
|
|
+ protected Object mapRow(ResultSet rs, int rownum)
|
|
|
+ throws SQLException {
|
|
|
+ return rs.getString("authority");
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|