Java 类org.hibernate.engine.spi.NamedSQLQueryDefinition 实例源码

项目：lams 文件：SQLQueryImpl.java

/**
 * Constructs a SQLQueryImpl given a sql query defined in the mappings.
 *
 * @param queryDef The representation of the defined <sql-query/>.
 * @param session The session to which this SQLQueryImpl belongs.
 * @param parameterMetadata Metadata about parameters found in the query.
 */
SQLQueryImpl(NamedSQLQueryDefinition queryDef, SessionImplementor session, ParameterMetadata parameterMetadata) {
    super( queryDef.getQueryString(), queryDef.getFlushMode(), session, parameterMetadata );
    if ( queryDef.getResultSetRef() != null ) {
        ResultSetMappingDefinition definition = session.getFactory()
                .getResultSetMapping( queryDef.getResultSetRef() );
        if (definition == null) {
            throw new MappingException(
                    "Unable to find resultset-ref definition: " +
                    queryDef.getResultSetRef()
                );
        }
        this.queryReturns = new ArrayList<NativeSQLQueryReturn>(Arrays.asList( definition.getQueryReturns() ));
    }
    else if ( queryDef.getQueryReturns() != null && queryDef.getQueryReturns().length > 0 ) {
        this.queryReturns = new ArrayList<NativeSQLQueryReturn>(Arrays.asList( queryDef.getQueryReturns()));
    }
    else {
        this.queryReturns = new ArrayList<NativeSQLQueryReturn>();
    }

    this.querySpaces = queryDef.getQuerySpaces();
    this.callable = queryDef.isCallable();
}

项目：lams 文件：AbstractSessionImpl.java

@Override
public Query getNamedQuery(String queryName) throws MappingException {
    errorIfClosed();
    NamedQueryDefinition nqd = factory.getNamedQuery( queryName );
    final Query query;
    if ( nqd != null ) {
        query = createQuery( nqd );
    }
    else {
        NamedSQLQueryDefinition nsqlqd = factory.getNamedSQLQuery( queryName );
        if ( nsqlqd==null ) {
            throw new MappingException( "Named query not known: " + queryName );
        }

        query = createSQLQuery( nsqlqd );
        nqd = nsqlqd;
    }
    initQuery( query, nqd );
    return query;
}

项目：lams 文件：AbstractSessionImpl.java

@Override
public Query getNamedSQLQuery(String queryName) throws MappingException {
    errorIfClosed();
    NamedSQLQueryDefinition nsqlqd = factory.getNamedSQLQuery( queryName );
    if ( nsqlqd==null ) {
        throw new MappingException( "Named SQL query not known: " + queryName );
    }
    Query query = new SQLQueryImpl(
            nsqlqd,
            this,
            factory.getQueryPlanCache().getSQLParameterMetadata( nsqlqd.getQueryString() )
    );
    query.setComment( "named native SQL query " + queryName );
    initQuery( query, nsqlqd );
    return query;
}

项目：lams 文件：NamedQueryRepository.java

public NamedQueryRepository(
        Iterable<NamedQueryDefinition> namedQueryDefinitions,
        Iterable<NamedSQLQueryDefinition> namedSqlQueryDefinitions,
        Iterable<ResultSetMappingDefinition> namedSqlResultSetMappings,
        Map<String, ProcedureCallMemento> namedProcedureCalls) {
    final HashMap<String, NamedQueryDefinition> namedQueryDefinitionMap = new HashMap<String, NamedQueryDefinition>();
    for ( NamedQueryDefinition namedQueryDefinition : namedQueryDefinitions ) {
        namedQueryDefinitionMap.put( namedQueryDefinition.getName(), namedQueryDefinition );
    }
    this.namedQueryDefinitionMap = Collections.unmodifiableMap( namedQueryDefinitionMap );


    final HashMap<String, NamedSQLQueryDefinition> namedSqlQueryDefinitionMap = new HashMap<String, NamedSQLQueryDefinition>();
    for ( NamedSQLQueryDefinition namedSqlQueryDefinition : namedSqlQueryDefinitions ) {
        namedSqlQueryDefinitionMap.put( namedSqlQueryDefinition.getName(), namedSqlQueryDefinition );
    }
    this.namedSqlQueryDefinitionMap = Collections.unmodifiableMap( namedSqlQueryDefinitionMap );

    final HashMap<String, ResultSetMappingDefinition> namedSqlResultSetMappingMap = new HashMap<String, ResultSetMappingDefinition>();
    for ( ResultSetMappingDefinition resultSetMappingDefinition : namedSqlResultSetMappings ) {
        namedSqlResultSetMappingMap.put( resultSetMappingDefinition.getName(), resultSetMappingDefinition );
    }
    this.namedSqlResultSetMappingMap = Collections.unmodifiableMap( namedSqlResultSetMappingMap );
    this.procedureCallMementoMap = Collections.unmodifiableMap( namedProcedureCalls );
}

项目：lams 文件：NamedQueryRepository.java

public synchronized void registerNamedQueryDefinition(String name, NamedQueryDefinition definition) {
    if ( NamedSQLQueryDefinition.class.isInstance( definition ) ) {
        throw new IllegalArgumentException( "NamedSQLQueryDefinition instance incorrectly passed to registerNamedQueryDefinition" );
    }

    if ( ! name.equals( definition.getName() ) ) {
        definition = definition.makeCopy( name );
    }

    final Map<String, NamedQueryDefinition> copy = CollectionHelper.makeCopy( namedQueryDefinitionMap );
    final NamedQueryDefinition previous = copy.put( name, definition );
    if ( previous != null ) {
        log.debugf(
                "registering named query definition [%s] overriding previously registered definition [%s]",
                name,
                previous
        );
    }

    this.namedQueryDefinitionMap = Collections.unmodifiableMap( copy );
}

项目：lams 文件：NamedQueryRepository.java

public synchronized void registerNamedSQLQueryDefinition(String name, NamedSQLQueryDefinition definition) {
    if ( ! name.equals( definition.getName() ) ) {
        definition = definition.makeCopy( name );
    }

    final Map<String, NamedSQLQueryDefinition> copy = CollectionHelper.makeCopy( namedSqlQueryDefinitionMap );
    final NamedQueryDefinition previous = copy.put( name, definition );
    if ( previous != null ) {
        log.debugf(
                "registering named SQL query definition [%s] overriding previously registered definition [%s]",
                name,
                previous
        );
    }

    this.namedSqlQueryDefinitionMap = Collections.unmodifiableMap( copy );
}

项目：base-framework 文件：BasicHibernateDao.java

/**
 * 根据查询SQL与参数列表创建SQLQuery对象
 * 
 * @param queryOrNamedSQLQuery query 或者 NamedSQLQuery
 * @param values 数量可变的参数,按顺序绑定.
 *            
 * @return {@link SQLQuery}
 */
protected SQLQuery createSQLQuery( String queryOrNamedSQLQuery,  Object... values) {
    Assert.hasText(queryOrNamedSQLQuery, "queryOrNamedSQLQuery不能为空");
    SessionFactoryImpl factory = (SessionFactoryImpl) sessionFactory;
    NamedSQLQueryDefinition nsqlqd = factory.getNamedSQLQuery( queryOrNamedSQLQuery );
    Query query = null;

    if (nsqlqd != null) {
        query = getSession().getNamedQuery(queryOrNamedSQLQuery);
    } else {
        query = getSession().createSQLQuery(queryOrNamedSQLQuery);
    }

    setQueryValues(query, values);
    SQLQuery sqlQuery = (SQLQuery)query;

    return sqlQuery.addEntity(entityClass);
}

项目：lams 文件：MetadataImpl.java

@Override
public void addNamedNativeQuery(NamedSQLQueryDefinition def) {
    if ( def == null || def.getName() == null ) {
        throw new IllegalArgumentException( "Named native query definition object or name is null: " + def.getQueryString() );
    }
    namedNativeQueryDefs.put( def.getName(), def );
}

项目：lams 文件：AbstractSessionImpl.java

@Override
public SQLQuery createSQLQuery(NamedSQLQueryDefinition namedQueryDefinition) {
    final ParameterMetadata parameterMetadata = factory.getQueryPlanCache().getSQLParameterMetadata( namedQueryDefinition.getQueryString() );
    final SQLQuery query = new SQLQueryImpl(
            namedQueryDefinition,
            this,
            parameterMetadata
    );
    query.setComment( "named native SQL query " + namedQueryDefinition.getName() );
    return query;
}

项目：lemon 文件：SessionFactoryWrapper.java

public NamedSQLQueryDefinition getNamedSQLQuery(String queryName) {
    return sessionFactoryImplementor.getNamedSQLQuery(queryName);
}

项目：lemon 文件：SessionFactoryWrapper.java

public void registerNamedSQLQueryDefinition(String name,
        NamedSQLQueryDefinition definition) {
    sessionFactoryImplementor.registerNamedSQLQueryDefinition(name,
            definition);
}