导入,适配开发

src/main/java/com/yihu/hos/standard/dao/IStdAdapterMetadataDao.java

@@ -0,0 +1,29 @@
package com.yihu.hos.standard.dao;
import com.yihu.hos.standard.model.adapter.AdapterMetadataModel;
import com.yihu.hos.web.framework.dao.XSQLGeneralDAO;
import java.util.List;
/**
 * Created by Administrator on 2016/5/4.
 */
public interface IStdAdapterMetadataDao extends XSQLGeneralDAO {
    List<AdapterMetadataModel> getAdapterMetadataByMetadateId(String metedataId) throws Exception;
    List<AdapterMetadataModel> getAdapterMetadataByDatasetIdAndStatus(String id, String s) throws Exception;
    void updateAdapterMetadataStatus(String id, String s) throws Exception;
    List<AdapterMetadataModel> getAdapterMetadataByAdaptMetadateId(String AdaptMetadateId)throws Exception;
    List<AdapterMetadataModel> getAdapterMetadataByMetadateIdAndStatus(String id, String type)throws Exception;
    List<AdapterMetadataModel> getAdapterMetadataByAdaptMetadateIdAndStdDataSetId(String AdaptMetadateId, String stdDataSetId)throws Exception;
    List<AdapterMetadataModel> getAdapterMetadataByProjectId(String id)throws Exception;
    List<AdapterMetadataModel> getAdapterMetadataByDatasetId(String dataSetId)throws Exception;
}

src/main/java/com/yihu/hos/standard/dao/IStdDataSetModelDao.java

@@ -0,0 +1,15 @@
package com.yihu.hos.standard.dao;
import com.yihu.hos.standard.model.standard.StdDataSetModel;
import com.yihu.hos.web.framework.dao.XSQLGeneralDAO;
import com.yihu.hos.web.framework.model.DataGridResult;
import java.util.List;
import java.util.Map;
/**
 * Created by Administrator on 2016/5/4.
 */
public interface IStdDataSetModelDao extends XSQLGeneralDAO {
    public StdDataSetModel getDatasetName(String version ,Integer id);
}

src/main/java/com/yihu/hos/standard/dao/IStdDictionaryEntryModelDao.java

@@ -0,0 +1,14 @@
package com.yihu.hos.standard.dao;
import com.yihu.hos.standard.model.standard.StdDictionaryEntryModel;
import com.yihu.hos.web.framework.dao.XSQLGeneralDAO;
import java.util.List;
/**
 * Created by Administrator on 2017/4/19 0019.
 */
public interface IStdDictionaryEntryModelDao extends XSQLGeneralDAO {
    List<StdDictionaryEntryModel> getDictionaryEntry(String adapter_std_version, String orgDicEntryValue,String orgDicValue);
}

src/main/java/com/yihu/hos/standard/dao/IStdDictionaryModelDao.java

@@ -0,0 +1,12 @@
package com.yihu.hos.standard.dao;
import com.yihu.hos.standard.model.standard.StdDictionaryModel;
import com.yihu.hos.web.framework.dao.XSQLGeneralDAO;
/**
 * Created by Administrator on 2016/5/4.
 */
public interface IStdDictionaryModelDao extends XSQLGeneralDAO {
    public StdDictionaryModel getDictionaryName(String version, Integer id);
}

src/main/java/com/yihu/hos/standard/dao/IStdMetaDataModelDao.java

@@ -0,0 +1,13 @@
package com.yihu.hos.standard.dao;
import com.yihu.hos.standard.model.standard.StdMetaDataModel;
import com.yihu.hos.web.framework.dao.XSQLGeneralDAO;
import java.util.List;
/**
 * Created by Administrator on 2016/5/4.
 */
public interface IStdMetaDataModelDao extends XSQLGeneralDAO {
    List<StdMetaDataModel> getMetadata(String adapter_std_version, String orgMetadataName,String orgDatasetName);
}

src/main/java/com/yihu/hos/standard/dao/StdAdapterMetadataDao.java

@@ -0,0 +1,88 @@
package com.yihu.hos.standard.dao;
import com.yihu.hos.standard.model.adapter.AdapterMetadataModel;
import com.yihu.hos.standard.model.standard.StdDataSetModel;
import com.yihu.hos.web.framework.dao.SQLGeneralDAO;
import org.springframework.stereotype.Repository;
import org.springframework.util.StringUtils;
import java.util.List;
/**
 * Created by Administrator on 2016/5/4.
 */
@Repository("stdeAdapterMetadataDao")
public class StdAdapterMetadataDao extends SQLGeneralDAO implements IStdAdapterMetadataDao {
    @Override
    public List<AdapterMetadataModel> getAdapterMetadataByMetadateId(String metedataId) throws Exception {
        String hql = " from StdeAdapterMetadata s where 1=1 ";
        if (!StringUtils.isEmpty(metedataId)) {
            hql += " and s.stdMatadataId='" + metedataId+ "'";
        }
        return super.getEntityList(StdDataSetModel.class, hql);
    }
    @Override
    public List<AdapterMetadataModel> getAdapterMetadataByDatasetIdAndStatus(String id, String s) throws Exception {
        String hql = " from StdeAdapterMetadata s where 1=1 ";
        if (!StringUtils.isEmpty(id)) {
            hql += " and s.stdDatasetId='" + id+ "'";
        }
        if (!StringUtils.isEmpty(s)) {
            hql += " and s.status='" + s+ "'";
        }
        return super.getEntityList(StdDataSetModel.class, hql);
    }
    @Override
    public void updateAdapterMetadataStatus(String id, String s) throws Exception {
//        super.getEntity(AdapterMetadataModel.class,id).setStatus(s);
    }
    @Override
    public List<AdapterMetadataModel> getAdapterMetadataByAdaptMetadateId(String AdaptMetadateId) throws Exception {
        String hql = " from StdeAdapterMetadata s where 1=1 ";
        if (!StringUtils.isEmpty(AdaptMetadateId)) {
            hql += " and s.adapterMatadataId='" + AdaptMetadateId+ "'";
        }
        return super.getEntityList(StdDataSetModel.class, hql);
    }
    @Override
    public List<AdapterMetadataModel> getAdapterMetadataByMetadateIdAndStatus(String id, String type) throws Exception {
        String hql = " from StdeAdapterMetadata s where 1=1 ";
        if (!StringUtils.isEmpty(id)) {
            hql += " and s.stdMatadataId='" + id+ "'";
        }
        if (!StringUtils.isEmpty(type)) {
            hql += " and s.status='" + type+ "'";
        }
        return super.getEntityList(StdDataSetModel.class, hql);
    }
    @Override
    public List<AdapterMetadataModel> getAdapterMetadataByAdaptMetadateIdAndStdDataSetId(String AdaptMetadateId, String stdDataSetId) throws Exception {
        String hql = " from StdeAdapterMetadata s where 1=1 ";
        if (!StringUtils.isEmpty(AdaptMetadateId)) {
            hql += " and s.adapterMatadataId='" + AdaptMetadateId+ "'";
        }
        if (!StringUtils.isEmpty(stdDataSetId)) {
            hql += " and s.stdDatasetId='" + stdDataSetId+ "'";
        }
        return super.getEntityList(StdDataSetModel.class, hql);
    }
    @Override
    public List<AdapterMetadataModel> getAdapterMetadataByProjectId(String id) throws Exception {
        String hql = " from StdeAdapterMetadata s where 1=1 and projectId='"+id+"' ";
        return super.getEntityList(StdDataSetModel.class, hql);
    }
    @Override
    public List<AdapterMetadataModel> getAdapterMetadataByDatasetId(String dataSetId) throws Exception {
        String hql = " from StdeAdapterMetadata s where 1=1 and stdDatasetId='"+dataSetId+"' ";
        return super.getEntityList(StdDataSetModel.class, hql);
    }
}

src/main/java/com/yihu/hos/standard/dao/StdDataSetModelDao.java

@@ -0,0 +1,30 @@
package com.yihu.hos.standard.dao;
import com.yihu.hos.standard.model.adapter.AdapterMetadataModel;
import com.yihu.hos.standard.model.standard.StdDataSetModel;
import com.yihu.hos.standard.service.bo.AdapterVersion;
import com.yihu.hos.web.framework.dao.SQLGeneralDAO;
import com.yihu.hos.web.framework.model.DataGridResult;
import com.yihu.hos.web.framework.util.sql.BeanTransformer;
import org.hibernate.Query;
import org.springframework.stereotype.Repository;
import org.springframework.util.StringUtils;
import java.util.List;
import java.util.Map;
/**
 * Created by Administrator on 2016/5/4.
 */
@Repository("stdeDatasetDao")
public class StdDataSetModelDao extends SQLGeneralDAO implements IStdDataSetModelDao {
    @Override
    public StdDataSetModel getDatasetName(String version ,Integer id){
        StringBuffer sql = new StringBuffer();
        sql.append("SELECT d.*").append(" FROM std_dataset_").append(version).append(" d where d.id ="+id);
        Query query = getCurrentSession().createSQLQuery(sql.toString());
        query.setResultTransformer(new BeanTransformer(StdDataSetModel.class));
        StdDataSetModel stdDataSetModel =(StdDataSetModel) query.uniqueResult();
        return stdDataSetModel;
    }
}

src/main/java/com/yihu/hos/standard/dao/StdDictionaryEntryModelDao.java

@@ -0,0 +1,26 @@
package com.yihu.hos.standard.dao;
import com.yihu.hos.standard.model.standard.StdDictionaryEntryModel;
import com.yihu.hos.web.framework.dao.SQLGeneralDAO;
import com.yihu.hos.web.framework.util.sql.BeanTransformer;
import org.hibernate.Query;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
 * Created by Administrator on 2017/4/19 0019.
 */
@Repository("stdDictionaryEntryDao")
public class StdDictionaryEntryModelDao extends SQLGeneralDAO implements IStdDictionaryEntryModelDao  {
    @Override
    public List<StdDictionaryEntryModel> getDictionaryEntry(String adapter_std_version, String orgDicEntryValue, String orgName) {
        StringBuffer sql = new StringBuffer();
        sql.append("SELECT m.*").append(" FROM std_dictionary_entry_"+adapter_std_version).append(" m inner join std_dictionary_"+adapter_std_version )
                .append(" d on d.id= m.dict_id where m.value like '%" + orgDicEntryValue + "%' and d.name like '%" + orgName+"%'");
        Query query = getCurrentSession().createSQLQuery(sql.toString());
        query.setResultTransformer(new BeanTransformer(StdDictionaryEntryModel.class));
        List<StdDictionaryEntryModel> list = query.list();
        return list;
    }
}

src/main/java/com/yihu/hos/standard/dao/StdDictionaryModelDao.java

@@ -0,0 +1,23 @@
package com.yihu.hos.standard.dao;
import com.yihu.hos.standard.model.standard.StdDictionaryModel;
import com.yihu.hos.web.framework.dao.SQLGeneralDAO;
import com.yihu.hos.web.framework.util.sql.BeanTransformer;
import org.hibernate.Query;
import org.springframework.stereotype.Repository;
/**
 * Created by Administrator on 2017/4/19 0019.
 */
@Repository("stdDictionaryDao")
public class StdDictionaryModelDao extends SQLGeneralDAO implements IStdDictionaryModelDao {
    @Override
    public StdDictionaryModel getDictionaryName(String version, Integer id) {
        StringBuffer sql = new StringBuffer();
        sql.append("SELECT d.*").append(" FROM std_dictionary_").append(version).append(" d where d.id ="+id);
        Query query = getCurrentSession().createSQLQuery(sql.toString());
        query.setResultTransformer(new BeanTransformer(StdDictionaryModel.class));
        StdDictionaryModel stdDictionaryModel =(StdDictionaryModel) query.uniqueResult();
        return stdDictionaryModel;
    }
}

src/main/java/com/yihu/hos/standard/dao/StdMetaDataModelDao.java

@@ -0,0 +1,25 @@
package com.yihu.hos.standard.dao;
import com.yihu.hos.standard.model.standard.StdMetaDataModel;
import com.yihu.hos.web.framework.dao.SQLGeneralDAO;
import com.yihu.hos.web.framework.util.sql.BeanTransformer;
import org.hibernate.Query;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
 * Created by Administrator on 2016/5/4.
 */
@Repository("stdeMetadataDao")
public class StdMetaDataModelDao extends SQLGeneralDAO implements IStdMetaDataModelDao {
    public List<StdMetaDataModel> getMetadata(String adapter_std_version, String orgMetadataName,String orgDatasetName){
        StringBuffer sql = new StringBuffer();
        sql.append("SELECT m.*").append(" FROM std_metadata_"+adapter_std_version).append(" m inner join std_dataset_"+adapter_std_version )
                .append(" d on d.id= m.dataset_id where m.name like '%" + orgMetadataName + "%' and d.name like '%" + orgDatasetName+"%'");
        Query query = getCurrentSession().createSQLQuery(sql.toString());
        query.setResultTransformer(new BeanTransformer(StdMetaDataModel.class));
        List<StdMetaDataModel> list = query.list();
        return list;
    }
}