001package gudusoft.gsqlparser.dlineage.metadata;
002
003import java.util.ArrayList;
004import java.util.List;
005
006import gudusoft.gsqlparser.EDbVendor;
007import gudusoft.gsqlparser.sqlenv.ESQLDataObjectType;
008import gudusoft.gsqlparser.util.SQLUtil;
009
010public class Sqlflow extends TreeNode {
011        private String createdBy;
012        private String createTime;
013        private List<Server> servers;
014        private List<Error> errorMessages;
015        private String physicalInstance;
016
017        public String getCreatedBy() {
018                return createdBy;
019        }
020
021        public void setCreatedBy(String createdBy) {
022                this.createdBy = createdBy;
023        }
024
025        public String getCreateTime() {
026                return createTime;
027        }
028
029        public void setCreateTime(String createTime) {
030                this.createTime = createTime;
031        }
032
033        public List<Server> getServers() {
034                return servers;
035        }
036
037        public void setServers(List<Server> servers) {
038                this.servers = servers;
039        }
040
041        public List<Error> getErrorMessages() {
042                return errorMessages;
043        }
044
045        public void setErrorMessages(List<Error> errorMessages) {
046                this.errorMessages = errorMessages;
047        }
048
049        public Server appendServer(Server server) {
050                if (server == null)
051                        return null;
052
053                if (this.servers == null) {
054                        this.servers = new ArrayList<Server>();
055                }
056
057                for (Server serverItem : servers) {
058                        if (SQLUtil.compareIdentifier(EDbVendor.valueOf(server.getDbVendor()), ESQLDataObjectType.dotCatalog,
059                                        serverItem.getName(), server.getName())) {
060                                return serverItem;
061                        }
062                }
063
064                this.servers.add(server);
065                return server;
066        }
067
068        public void appendError(Error error) {
069                if (error == null) {
070                        return;
071                }
072                if (errorMessages == null) {
073                        errorMessages = new ArrayList<Error>();
074                }
075                errorMessages.add(error);
076        }
077
078        public String getPhysicalInstance() {
079                return physicalInstance;
080        }
081
082        public void setPhysicalInstance(String physicalInstance) {
083                this.physicalInstance = physicalInstance;
084        }
085}