Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Copyright 2013 Harald Wellmann
   *
   * 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 org.ops4j.orient.adapter.impl;
 
 import java.util.Set;
 
 

Author(s):
Harald Wellmann
 
 // @formatter:off
     connectionFactory = OrientDatabaseConnectionFactory.class
     connectionFactoryImpl = OrientDatabaseConnectionFactoryImpl.class
     connection = OrientDatabaseConnection.class,
     connectionImpl = OrientDatabaseConnectionImpl.class)
 // @formatter:on
 
     private static final long serialVersionUID = 1L;
 
     private static Logger log = LoggerFactory.getLogger(OrientManagedConnectionFactoryImpl.class);
     
     
     private PrintWriter logWriter;
     private OrientResourceAdapter ra;
 
     @ConfigProperty(defaultValue = "document")
     private String type;
     
     @ConfigProperty
     private String connectionUrl;
     
     @ConfigProperty(defaultValue = "admin")
     private String username;
     
     @ConfigProperty(defaultValue = "admin")
     private String password;
     
 
         this. = new PrintWriter(.);
     }
 
     @Override
     public Object createConnectionFactory(ConnectionManager cxManagerthrows ResourceException {
         .debug("creating managed connection factory");
         validate();
         return new OrientDatabaseConnectionFactoryImpl(thiscxManager);
     }
     
     private void validate() throws ResourceException {
         if ( == null || .trim().isEmpty()) {
             throw new ResourceException("configuration property [connectionUrl] must not be empty");
         }
         
         if (!Arrays.asList("document""graph""object").contains()) {
             throw new ResourceException("configuration property [type] must be one of 'document', 'graph', 'object'");            
         }
     }
 
     @Override
     public Object createConnectionFactory() throws ResourceException {
         throw new ResourceException("unmanaged environments are not supported");
     }
 
    @Override
        ConnectionRequestInfo cxRequestInfothrows ResourceException {
        .debug("creating managed connection");
        return new OrientManagedConnectionImpl(thiscxRequestInfo);
    }
    @SuppressWarnings({ "rawtypes""unchecked""resource" })
    @Override
    public ManagedConnection matchManagedConnections(Set connectionSetSubject subject,
        ConnectionRequestInfo cxRequestInfothrows ResourceException {
        Set<ManagedConnectionconnections = connectionSet;
        for (ManagedConnection connection : connections) {
            if (connection instanceof OrientManagedConnectionImpl) {
                OrientManagedConnectionImpl orientConnection = (OrientManagedConnectionImplconnection;
                ConnectionRequestInfo cri = orientConnection.getConnectionRequestInfo();
                if (cri == null || cri.equals(cxRequestInfo)) {
                    return connection;
                }
            }
        }
        return null;
    }
    @Override
    public void setLogWriter(PrintWriter outthrows ResourceException {
        this. = out;
    }
    @Override
    public PrintWriter getLogWriter() throws ResourceException {
        return ;
    }
    @Override
        return ;
    }
    @Override
    public void setResourceAdapter(ResourceAdapter rathrows ResourceException {
        this. = (OrientResourceAdapterra;
    }
    @Override
    }

    

Returns:
the connectionUrl
    public String getConnectionUrl() {
        return ;
    }

    
    

Parameters:
connectionUrl the connectionUrl to set
    public void setConnectionUrl(String connectionUrl) {
        this. = connectionUrl;
    }
    
    

Returns:
the username
    public String getUsername() {
        return ;
    }

    
    

Parameters:
username the username to set
    public void setUsername(String username) {
        this. = username;
    }

    
    

Returns:
the password
    public String getPassword() {
        return ;
    }

    
    

Parameters:
password the password to set
    public void setPassword(String password) {
        this. = password;
    }

    
    

Returns:
the type
    public String getType() {
        return ;
    }

    
    

Parameters:
type the type to set
    public void setType(String type) {
        this. = type;
    }
    @Override
    public int hashCode() {
        final int prime = 31;
        int result = 1;
        result = prime * result + (( == null) ? 0 : .hashCode());
        return result;
    }
    @Override
    public boolean equals(Object obj) {
        if (this == obj) {
            return true;
        }
        if (obj == null) {
            return false;
        }
        if (getClass() != obj.getClass()) {
            return false;
        }
        if ( == null) {
            if (other.ra != null) {
                return false;
            }
        }
        else if (!.equals(other.ra)) {
            return false;
        }
        return true;
    }
New to GrepCode? Check out our FAQ X