import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
static Table createTableModel(DatabaseChannel channel, DbEntity dbEntity) {

        Column[] columns = new Column[dbEntity.getAttributes().size()];
        int i = 0;
        for (DbAttribute a : dbEntity.getAttributes()) {
            columns[i++] = new Column(Objects.requireNonNull(a.getName()), a.getType());
        }

        // ensure predictable column order .. DbEntity's attributes are presumably already sorted, but just in case
        Arrays.sort(columns, (c1, c2) -> c1.getName().compareTo(c2.getName()));

        return Table.builder(channel, dbEntity.getFullyQualifiedName())
                .columns(columns)
                .quoteSqlIdentifiers(dbEntity.getDataMap().isQuotingSQLIdentifiers())
                .build();
    }
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
public static AttributeInfo forAttribute(final DbAttribute attribute) {
    return new AttributeInfo() {
        @Override
        public String getNormalizedPath() {
            return ASTDbPath.DB_PREFIX + attribute.getName();
        }

        @Override
        public int getType() {
            return attribute.getType();
        }

        @Override
        public DbAttribute getTarget() {
            return attribute;
        }
    };
}
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
public static AttributeInfo forRelationship(final DbJoin join) {
    return new AttributeInfo() {
        @Override
        public String getNormalizedPath() {
            return ASTDbPath.DB_PREFIX + join.getSourceName();
        }

        @Override
        public int getType() {
            return join.getSource().getType();
        }

        @Override
        public DbAttribute getTarget() {
            return join.getTarget();
        }
    };
}
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
private static ObjAttribute fakeObjAttribute(String name, DbAttribute dbAttribute) {
	ObjAttribute a = new ObjAttribute(name) {
		@Override
		public DbAttribute getDbAttribute() {
			return dbAttribute;
		}
	};
	a.setDbAttributePath(dbAttribute.getName());

	String javaType = TypesMapping.getJavaBySqlType(dbAttribute.getType());
	if (javaType == null) {
		throw new NullPointerException("Java type not found for SQL type: " + dbAttribute.getType());
	}
	a.setType(javaType);
	return a;
}
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
private void setPrimaryKey(DataObject o, ObjEntity entity, DbAttribute pk, Object id) {

        // 1. meaningful ID
        // TODO: must compile all this... figuring this on the fly is
        // slow
        ObjAttribute opk = entity.getAttributeForDbAttribute(pk);
        if (opk != null) {
            o.writeProperty(opk.getName(), id);
        }
        // 2. PK is auto-generated ... I guess this is sorta
        // expected to fail - generated meaningless PK should not be
        // pushed from the client
        else if (pk.isGenerated()) {
            throw new LinkRestException(Response.Status.BAD_REQUEST, "Can't create '" + entity.getName()
                    + "' with fixed id");
        }
        // 3. probably a propagated ID.
        else {
            // TODO: hopefully this works..
            o.getObjectId().getReplacementIdMap().put(pk.getName(), id);
        }
    }
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
/**
 * Return the database primary key column name for the given data object.
 *
 * @param dataObjectClass the class of the data object
 * @return the primary key column name
 */
protected String getPkName(Class dataObjectClass) {
    Validate.notNull(dataObjectClass, "Null dataObjectClass parameter.");

    ObjEntity objEntity =
            getDataContext().getEntityResolver().lookupObjEntity(dataObjectClass);

    if (objEntity == null) {
        throw new CayenneRuntimeException("Unmapped DataObject Class: "
                + dataObjectClass.getName());
    }

    DbEntity dbEntity = objEntity.getDbEntity();
    if (dbEntity == null) {
        throw new CayenneRuntimeException("No DbEntity for ObjEntity: "
                + objEntity.getName());
    }

    List pkAttributes = dbEntity.getPrimaryKey();
    if (pkAttributes.size() != 1) {
        throw new CayenneRuntimeException("PK contains "
                + pkAttributes.size()
                + " columns, expected 1.");
    }

    DbAttribute attr = (DbAttribute) pkAttributes.get(0);

    return attr.getName();
}
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
public TargetPropertyWriter getOrCreatePkWriter(DbAttribute pkAttribute) {

        if (!entity.getDbEntity().equals(pkAttribute.getEntity())) {
            throw new LmRuntimeException("Attribute belongs to different entity: " + pkAttribute.getName());
        }

        return getOrCreateWriter(
                pkAttribute.getName(),
                ASTDbPath.DB_PREFIX + pkAttribute.getName(),
                new TargetPkPropertyWriter(pkAttribute)
        );
    }
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
/**
 * @since 1.7
 */
@SuppressWarnings("unchecked")
public T normalize(Object value, DbAttribute targetAttribute) {

    T result;
    if (value == null) {
        result = null;
    } else if (type.isAssignableFrom(value.getClass())) {
        result = (T) value;
    } else {
        result = doNormalize(value, targetAttribute);
    }

    return postNormalize(result, targetAttribute);
}
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
/**
 * @since 1.7
 * @deprecated since 2.4 in favor of {@link #valueConverter(Class, ValueConverter)}.
 */
@Deprecated
public LmRuntimeBuilder withJdbcNormalizer(Class<?> javaType, JdbcNormalizer<?> normalizer) {
    return valueConverter(javaType, (v, s) -> {
        DbAttribute placeholder = new DbAttribute("_placeholder");
        placeholder.setScale(s);
        placeholder.setType(TypesMapping.getSqlTypeByJava(javaType));
        return normalizer.normalize(v, placeholder);
    });
}
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
public MapperBuilder matchById() {

		Collection<DbAttribute> pks = entity.getDbEntity().getPrimaryKeys();
		if (pks.isEmpty()) {
			throw new IllegalStateException("Target entity has no PKs defined: " + entity.getDbEntityName());
		}

		for (DbAttribute pk : pks) {
			this.paths.add(ASTDbPath.DB_PREFIX + pk.getName());
		}

		return this;
	}
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
/**
 * @return true if all PK columns are represented in {@code keys}
 */
private boolean isPrimaryKey(DbEntity entity, Collection<String> keys) {
    Collection<DbAttribute> pks = entity.getPrimaryKeys();
    for (DbAttribute pk : pks) {
        if (!keys.contains(pk.getName())) {
            return false;
        }
    }
    return true;
}
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
/**
 * Override this method to do post-processing of the normalized value
 * (e.g. additional scaling of a decimal)
 */
protected T postNormalize(T normalized, DbAttribute targetAttribute) {
    // by default just return the value
    return normalized;
}
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
/**
 * @since 1.24
    */
public CayenneLrDbAttribute(String name, DbAttribute dbAttribute, Class<?> type) {
	super(fakeObjAttribute(name, dbAttribute), type);
	this.dbAttribute = dbAttribute;
}
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
public TargetPkPropertyWriter(DbAttribute pk) {

		if (!pk.isPrimaryKey()) {
			throw new LmRuntimeException("'" + pk.getName() + "' is not a PK");
		}

		this.pk = pk;

	}
 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
protected abstract T doNormalize(Object value, DbAttribute targetAttribute); 

import org.apache.cayenne.map.DbAttribute; //导入依赖的package包/类
public abstract DbAttribute getTarget();