基于Spring生态的动态数据库ORM设计源码

/* * Copyright 2006-2023 www.anyline.org * * 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.anyline.data.adapter.init; import org.anyline.adapter.DataReader; import org.anyline.adapter.DataWriter; import org.anyline.adapter.EntityAdapter; import org.anyline.adapter.KeyAdapter; import org.anyline.data.adapter.DriverWorker; import org.anyline.proxy.ConvertProxy; import org.anyline.data.adapter.DriverAdapter; import org.anyline.data.prepare.SyntaxHelper; import org.anyline.data.prepare.init.DefaultVariable; import org.anyline.metadata.graph.EdgeTable; import org.anyline.metadata.graph.VertexTable; import org.anyline.util.SQLUtil; import org.anyline.metadata.adapter.MetadataAdapterHolder; import org.anyline.data.cache.PageLazyStore; import org.anyline.data.listener.DDListener; import org.anyline.data.listener.DMListener; import org.anyline.data.metadata.TypeMetadataAlias; import org.anyline.metadata.adapter.ColumnMetadataAdapter; import org.anyline.metadata.adapter.IndexMetadataAdapter; import org.anyline.metadata.adapter.PrimaryMetadataAdapter; import org.anyline.metadata.adapter.TableMetadataAdapter; import org.anyline.metadata.type.init.StandardTypeMetadata; import org.anyline.data.param.Config; import org.anyline.data.param.ConfigParser; import org.anyline.data.param.ConfigStore; import org.anyline.data.param.init.DefaultConfigStore; import org.anyline.data.prepare.RunPrepare; import org.anyline.data.prepare.Variable; import org.anyline.data.prepare.auto.TablePrepare; import org.anyline.data.prepare.auto.TextPrepare; import org.anyline.data.prepare.auto.init.DefaultTablePrepare; import org.anyline.data.prepare.auto.init.DefaultTextPrepare; import org.anyline.data.prepare.xml.XMLPrepare; import org.anyline.data.run.*; import org.anyline.data.runtime.DataRuntime; import org.anyline.data.util.DataSourceUtil; import org.anyline.entity.*; import org.anyline.entity.generator.GeneratorConfig; import org.anyline.entity.generator.PrimaryGenerator; import org.anyline.exception.AnylineException; import org.anyline.exception.SQLUpdateException; import org.anyline.metadata.*; import org.anyline.metadata.type.TypeMetadata; import org.anyline.metadata.type.DatabaseType; import org.anyline.proxy.CacheProxy; import org.anyline.proxy.EntityAdapterProxy; import org.anyline.proxy.InterceptorProxy; import org.anyline.util.*; import org.anyline.util.regular.Regular; import org.anyline.util.regular.RegularUtil; import java.lang.reflect.Field; import java.util.*; /** * SQL生成 子类主要实现与分页相关的SQL 以及delimiter */ public abstract class AbstractDriverAdapter implements DriverAdapter { protected DMListener dmListener; protected DDListener ddListener; protected PrimaryGenerator primaryGenerator; protected DriverWorker worker; protected DMListener getListener() { return dmListener; } public void setListener(DMListener listener) { this.dmListener = listener; } public DMListener getDMListener(){ return this.dmListener; } public void setListener(DDListener listener) { this.ddListener = listener; } public DDListener getDDListener(){ return this.ddListener; } public void setGenerator(PrimaryGenerator generator){ this.primaryGenerator = generator; } public PrimaryGenerator getPrimaryGenerator() { return primaryGenerator; } protected String delimiterFr = ""; protected String delimiterTo = ""; //拼写兼容 下划线空格兼容 protected static Map<String, String> spells = new HashMap<>(); //根据名称定位数据类型 protected LinkedHashMap<String, TypeMetadata> alias = new LinkedHashMap(); static { for(StandardTypeMetadata type: StandardTypeMetadata.values()){ String name = type.name().toUpperCase();//变量名 String standard = type.getName().toUpperCase(); //标准SQL类型名 spells.put(name, standard); if(name.contains(" ")) { spells.put(name.replace(" ", "_"), standard); } if(name.contains("_")){ spells.put(name.replace("_", " "), standard); } if(standard.contains(" ")) { spells.put(standard.replace(" ", "_"), standard); } if(standard.contains("_")) { spells.put(standard.replace("_", " "), standard); } } } @Override public void setWorker(DriverWorker worker){ this.worker = worker; } @Override public DriverWorker getWorker(){ return worker; } @Override public String getDelimiterFr(){ return this.delimiterFr; } @Override public String getDelimiterTo(){ return this.delimiterTo; } public void setDelimiter(String delimiter){ if(BasicUtil.isNotEmpty(delimiter)){ delimiter = delimiter.replaceAll("\\s",""); if(delimiter.length() == 1){ this.delimiterFr = delimiter; this.delimiterTo = delimiter; }else{ this.delimiterFr = delimiter.substring(0,1); this.delimiterTo = delimiter.substring(1,2); } } } public DatabaseType compatible(){ return null; } public AbstractDriverAdapter(){ //当前数据库支持的数据类型,子类根据情况覆盖 for(StandardTypeMetadata type: StandardTypeMetadata.values()){ reg(type, type.config()); List<DatabaseType> dbs = type.databaseTypes(); for(DatabaseType db:dbs){ if(db == this.type()){ //column type支持当前db alias(type.getName(), type); alias(type.name(), type); break; } } } MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.CHAR, new TypeMetadata.Config(0, 1, 1)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.TEXT, new TypeMetadata.Config(1, 1, 1)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.BOOLEAN, new TypeMetadata.Config( 1,1, 1)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.BYTES, new TypeMetadata.Config(0, 1, 1)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.BLOB, new TypeMetadata.Config(1,1,1)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.INT, new TypeMetadata.Config(1, 1, 1)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.FLOAT, new TypeMetadata.Config(1, 0, 0)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.DATE, new TypeMetadata.Config(1, 1, 1)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.TIME, new TypeMetadata.Config(1, 1, 1)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.DATETIME, new TypeMetadata.Config( 1, 1, 1)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.TIMESTAMP, new TypeMetadata.Config(1, 1, 1)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.COLLECTION, new TypeMetadata.Config(1, 1, 1)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.GEOMETRY, new TypeMetadata.Config(1, 1, 1)); MetadataAdapterHolder.reg(type(), TypeMetadata.CATEGORY.OTHER, new TypeMetadata.Config( 1, 1, 1)); } public LinkedHashMap<String, TypeMetadata> alias(){ return alias; } /** * 注册数据类型别名(包含对应的标准类型、length/precision/scale等配置) * @param alias 数据类型别名 * @return Config */ @Override public TypeMetadata.Config reg(TypeMetadataAlias alias){ TypeMetadata standard = alias.standard(); if(standard == StandardTypeMetadata.NONE){ return null; } alias(alias.input(), standard); //根据别名 alias(standard.getName(), standard); //根据实现SQL数据类型名称 TypeMetadata.Config config = alias.config(); reg(alias.input(), config); reg(alias.standard(), config); return config; } protected void alias(String key, TypeMetadata value){ if(null != k