Changeset 26 for trunk/fmgVen/src


Ignore:
Timestamp:
Jan 2, 2011, 8:51:21 PM (13 years ago)
Author:
fmguler
Message:

Refs #3 - Ven.save() is transferred to the new package. Save use case is completed. Convert.toDB() converts camel case object names to database names with underscores. Unchecked VenException is thrown by Ven methods. Liquibase changelog (test-db-changelog.xml) is changed to include only a simple object to test save operation. It creates a sample database table and inserts a sample row. On rollback it removes sample data. Using liquibase, Sample.java builds database, tests save operation and rolls back.

QueryGenerator generates insert and update queries for save and generates sequence query to assign ids to new objects. Ven calls query generator and runs the query using spring jdbc template.

Old codebase updated to run at Java 1.4

Location:
trunk/fmgVen/src
Files:
3 added
7 edited

Legend:

Unmodified
Added
Removed

  • trunk/fmgVen/src/com/fmguler/ven/QueryGenerator.java

    r23 r26  
    1818package com.fmguler.ven; 
    1919 
     20import com.fmguler.ven.util.Convert; 
     21import java.beans.PropertyDescriptor; 
     22import java.util.Date; 
    2023import java.util.HashSet; 
    2124import java.util.Set; 
     25import org.springframework.beans.BeanWrapper; 
     26import org.springframework.beans.BeanWrapperImpl; 
    2227 
    2328/** 
    … …  
    2732public class QueryGenerator { 
    2833    private Set domainPackages; 
     34    private Set dbClasses; 
    2935 
    3036    public QueryGenerator() { 
    3137        domainPackages = new HashSet(); 
     38        dbClasses = new HashSet(); 
     39        //the predefined database classes; 
     40        this.dbClasses.add(Integer.class); 
     41        this.dbClasses.add(String.class); 
     42        this.dbClasses.add(Date.class); 
     43        this.dbClasses.add(Double.class); 
     44        this.dbClasses.add(Boolean.class); 
    3245    } 
    3346 
    … …  
    4053    } 
    4154 
    42     public String generateUpdateQuery() { 
    43         return null; 
     55    public String generateInsertQuery(Object object) throws VenException { 
     56        BeanWrapper wr = new BeanWrapperImpl(object); 
     57        String objectName = Convert.toSimpleName(object.getClass().getName()); 
     58        String tableName = Convert.toDB(objectName); 
     59        PropertyDescriptor[] pdArr = wr.getPropertyDescriptors(); 
     60 
     61        //generate insert query 
     62        StringBuffer query = new StringBuffer("insert into " + tableName + "("); 
     63        StringBuffer values = new StringBuffer(" values("); 
     64        for (int i = 0; i < pdArr.length; i++) { 
     65            Class fieldClass = pdArr[i].getPropertyType(); //field class 
     66            String columnName = Convert.toDB(pdArr[i].getName()); //column name 
     67            String fieldName = pdArr[i].getName(); //field name 
     68            //if (fieldName.equals("id")) continue; //remove if it does not break the sequence 
     69            if (dbClasses.contains(fieldClass)) { //direct database field (Integer,String,Date, etc) 
     70                query.append(columnName); 
     71                query.append(","); 
     72                values.append(":").append(fieldName); 
     73                values.append(","); 
     74            } 
     75            if (fieldClass.getPackage() != null && domainPackages.contains(fieldClass.getPackage().getName())) { //object 
     76                query.append(Convert.toDB(fieldName)).append("_id"); 
     77                query.append(","); 
     78                values.append(":").append(fieldName).append(".id"); 
     79                values.append(","); 
     80            } 
     81        } 
     82        query.deleteCharAt(query.length() - 1); 
     83        query.append(")"); 
     84        values.deleteCharAt(values.length() - 1); 
     85        values.append(");"); 
     86        query.append(values); 
     87 
     88        return query.toString(); 
    4489    } 
    4590 
    46     //SETTERS------------------------------------------------------------------- 
     91    /** 
     92     * Generates insert/update query 
     93     * @return the insert update SQL query 
     94     */ 
     95    public String generateUpdateQuery(Object object) throws VenException { 
     96        BeanWrapper wr = new BeanWrapperImpl(object); 
     97        String objectName = Convert.toSimpleName(object.getClass().getName()); 
     98        String tableName = Convert.toDB(objectName); 
     99        PropertyDescriptor[] pdArr = wr.getPropertyDescriptors(); 
     100 
     101        StringBuffer query = new StringBuffer("update " + tableName + " set "); 
     102        for (int i = 0; i < pdArr.length; i++) { 
     103            Class fieldClass = pdArr[i].getPropertyType(); //field class 
     104            String columnName = Convert.toDB(pdArr[i].getName()); //column name 
     105            String fieldName = pdArr[i].getName(); //field name 
     106            if (dbClasses.contains(fieldClass)) { //direct database field (Integer,String,Date, etc) 
     107                query.append(columnName).append("=:").append(fieldName); 
     108                query.append(","); 
     109            } 
     110            if (fieldClass.getPackage() != null && domainPackages.contains(fieldClass.getPackage().getName())) { //object 
     111                query.append(columnName).append("_id=:").append(fieldName).append(".id"); 
     112                query.append(","); 
     113            } 
     114        } 
     115        query.deleteCharAt(query.length() - 1); 
     116        query.append(" where id = :id ;"); //TODO: remove the last comma 
     117        return query.toString(); 
     118    } 
     119 
     120    public String generateSequenceQuery(Object object) throws VenException { 
     121        String objectName = Convert.toSimpleName(object.getClass().getName()); 
     122        String tableName = Convert.toDB(objectName); 
     123        return "select nextval('" + tableName + "_id_seq');"; 
     124    } 
     125 
     126    //-------------------------------------------------------------------------- 
     127    //SETTERS 
    47128    public void addDomainPackage(String domainPackage) { 
    48129        domainPackages.add(domainPackage); 

  • trunk/fmgVen/src/com/fmguler/ven/Ven.java

    r25 r26  
    1818package com.fmguler.ven; 
    1919 
     20import java.util.HashMap; 
    2021import java.util.List; 
    2122import javax.sql.DataSource; 
     23import org.springframework.beans.BeanWrapper; 
     24import org.springframework.beans.BeanWrapperImpl; 
     25import org.springframework.jdbc.core.namedparam.BeanPropertySqlParameterSource; 
    2226import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate; 
     27import org.springframework.jdbc.core.namedparam.SqlParameterSource; 
    2328 
    2429/** 
    … …  
    4449    } 
    4550 
    46     public Object get(int no, Class objectClass) { 
     51    public Object get(int id, Class objectClass) { 
    4752        return null; 
    4853    } 
    4954 
     55    /** 
     56     * Save the object. If it has a "id" property it will be updated. 
     57     * It will be inserted otherwise. 
     58     * <p> 
     59     * The object will be saved to a table with the same name as the object, 
     60     * The fields of object will be mapped to the table fields. 
     61     *  
     62     * @param object the object to be saved 
     63     */ 
    5064    public void save(Object object) { 
     65        String query = null; 
     66 
     67        if (isObjectNew(object)) { 
     68            //if this is a new object assign a new id first 
     69            generateId(object); 
     70            query = generator.generateInsertQuery(object); 
     71        } else { 
     72            query = generator.generateUpdateQuery(object); 
     73        } 
     74 
     75        //execute the insert/update query 
     76        SqlParameterSource parameterSource = new BeanPropertySqlParameterSource(object); 
     77        template.update(query, parameterSource); 
    5178    } 
    5279 
    53     public void delete(int no, Class objectClass) { 
     80    public void delete(int id, Class objectClass) { 
    5481    } 
    5582 
    56     //SETTERS------------------------------------------------------------------- 
     83    //-------------------------------------------------------------------------- 
     84    //PRIVATE METHODS 
     85    //return true if the object id is zero or null false otherwise 
     86    private boolean isObjectNew(Object object) throws VenException { 
     87        BeanWrapper beanWrapper = new BeanWrapperImpl(object); 
     88        Object objectId = beanWrapper.getPropertyValue("id");  
     89        if (objectId == null) return true; 
     90        if (!(objectId instanceof Integer)) throw new VenException(VenException.EC_GENERATOR_OBJECT_ID_TYPE_INVALID); 
     91        return ((Integer)objectId).intValue() == 0; 
     92    } 
     93 
     94    //set new object id 
     95    private void generateId(Object object) { 
     96        Integer newObjectId = new Integer(template.queryForInt(generator.generateSequenceQuery(object), new HashMap())); 
     97        BeanWrapper beanWrapper = new BeanWrapperImpl(object); 
     98        beanWrapper.setPropertyValue("id", newObjectId); 
     99    } 
     100 
     101    //-------------------------------------------------------------------------- 
     102    //SETTERS 
    57103    public void setDataSource(DataSource dataSource) { 
    58104        if (dataSource == null) throw new RuntimeException("fmgVen - DataSource cannot be null"); 

  • trunk/fmgVen/src/net/fmg/ven/Olcut.java

    r22 r26  
    77 * Ven - Ayar Yerine Gelenek veritabanı erişim nesnesi 
    88 */ 
    9  
    109package net.fmg.ven; 
    1110 
    … …  
    2524    private Map parametreler; 
    2625    private Set baglaclar; 
    27      
     26 
    2827    /**  
    2928     * Yeni ölçüt 
    … …  
    3231        this.metin = ""; 
    3332        this.parametreler = new HashMap(); 
    34         this.baglaclar =  new HashSet(); 
     33        this.baglaclar = new HashSet(); 
    3534        //{"and", "or", "=", "<>", "<", ">"} 
    3635    } 
    37      
     36 
    3837    /** 
    3938     * YAPILMADI 
    4039     */ 
    41     public Olcut ekle(Olcut olcut){         
     40    public Olcut ekle(Olcut olcut) { 
    4241        return null; 
    4342    } 
    44      
     43 
    4544    /** 
    4645     * YAPILMADI 
    4746     */ 
    48     public Olcut ekle(List olcutler){         
     47    public Olcut ekle(List olcutler) { 
    4948        return null; 
    5049    } 
    51      
     50 
    5251    /** 
    5352     * YAPILMADI 
    5453     */ 
    55     public Olcut ve(){ 
     54    public Olcut ve() { 
    5655        return null; 
    5756    } 
    58      
     57 
    5958    /** 
    6059     * koşul ekle 
    6160     */ 
    62     public Olcut ekle(String kosul){ 
    63         this.metin +=" "+kosul; 
     61    public Olcut ekle(String kosul) { 
     62        this.metin += " " + kosul; 
    6463        return this; 
    6564    } 
    66      
     65 
    6766    /** 
    6867     * koşullarda kullanılan parametreleri ekle 
    6968     */ 
    70     public Olcut ekle(String parametre, Object nesne){ 
    71         this.parametreler.put(parametre,nesne); 
     69    public Olcut ekle(String parametre, Object nesne) { 
     70        this.parametreler.put(parametre, nesne); 
    7271        return this; 
    7372    } 
    74      
     73 
    7574    /** 
    7675     * koşullarda kullanılan parametreleri tümden ekle 
    7776     */ 
    78     public Olcut ekle(Map parametreler){ 
     77    public Olcut ekle(Map parametreler) { 
    7978        this.parametreler.putAll(parametreler); 
    8079        return this; 
    8180    } 
    82      
    83     public String olcutleriAl(){ 
     81 
     82    public String olcutleriAl() { 
    8483        //((1=1) and ((1=1) and (musteri_numuneler_numune_sahibi.rapor_tarihi is null) and (musteri.no = 4))) 
    8584        //Musteri.numuneler.deneyler.deneyTip.ad like :p1 
    8685        String sonuc = ""; 
    87         metin = metin.replace("(","( "); 
    88         metin = metin.replace(")"," )"); 
     86        metin = metin.replaceAll("\\(", "\\( "); 
     87        metin = metin.replaceAll("\\)", " \\)"); 
    8988        String[] parcalar = metin.split(" "); 
    9089        for (int i = 0; i < parcalar.length; i++) { 
    91             if (!parcalar[i].startsWith(":") && parcalar[i].contains(".")){ 
    92                 int sonNokta = parcalar[i].lastIndexOf('.');                 
     90            if (!parcalar[i].startsWith(":") && parcalar[i].indexOf(".") >= 0) { 
     91                int sonNokta = parcalar[i].lastIndexOf('.'); 
    9392                sonuc += " "; 
    94                 int u = parcalar[i].length();                 
    95                 sonuc +=Cevir.vt(parcalar[i].substring(0,sonNokta).replace('.','_')); 
    96                 sonuc +=Cevir.vt(parcalar[i].substring(sonNokta,u)); 
    97             }else{ 
    98                 sonuc += " "+parcalar[i]; 
     93                int u = parcalar[i].length(); 
     94                sonuc += Cevir.vt(parcalar[i].substring(0, sonNokta).replace('.', '_')); 
     95                sonuc += Cevir.vt(parcalar[i].substring(sonNokta, u)); 
     96            } else { 
     97                sonuc += " " + parcalar[i]; 
    9998            } 
    10099        } 
    101100        return sonuc; 
    102101    } 
    103      
    104     public Map parametreler(){ 
     102 
     103    public Map parametreler() { 
    105104        return this.parametreler; 
    106105    } 
    107106 
    108107    public String toString() { 
    109         return olcutleriAl()+" "+this.parametreler; 
     108        return olcutleriAl() + " " + this.parametreler; 
    110109    } 
    111      
    112110} 

  • trunk/fmgVen/src/net/fmg/ven/SorguEslestirici.java

    r23 r26  
    5757        long t1 = System.currentTimeMillis(); 
    5858        final List sonuclar = new LinkedList(); 
    59         final String tabloAdi = Cevir.vt(nesneSinifi.getSimpleName()); 
     59        final String tabloAdi = Cevir.vt(Cevir.isim(nesneSinifi.getName())); 
    6060        final Set sutunlar = new HashSet(); 
    6161         

  • trunk/fmgVen/src/net/fmg/ven/SorguUretici.java

    r22 r26  
    5959            if (alanSinifi.getPackage()!=null && nesnePaketleri.contains(alanSinifi.getPackage().getName()) && baglarKapsar(baglar,nesneYolu+"."+alanAdi)){ //domain nesnesi 1-1 join 
    6060                String bagTablosuDigerAd = tabloAdi+"_"+sutunAdi; // bağ tablosu için diğer ad, çünkü aynı isimde birden fazla bağ olabilir, karışmasın 
    61                 String bagTablosu = Cevir.vt(alanSinifi.getSimpleName());//gerçek bağ tablosu 
     61                String bagTablosu = Cevir.vt(Cevir.isim(alanSinifi.getName()));//gerçek bağ tablosu 
    6262                fromCumlesi.append(" left join "+bagTablosu+" "+bagTablosuDigerAd); 
    6363                fromCumlesi.append(" on "+bagTablosuDigerAd+".no = "+tabloAdi+"."+sutunAdi+"_no"); 
    … …  
    6767                Class cokluAlandakiNesneSinifi = (Class)wr.getPropertyValue(alanAdi+".nesneSinifi"); 
    6868                String bagTablosuDigerAd = tabloAdi+"_"+sutunAdi; // bağ tablosu için diğer ad, çünkü aynı isimde birden fazla bağ olabilir, karışmasın 
    69                 String bagTablosu = Cevir.vt(cokluAlandakiNesneSinifi.getSimpleName());//gerçek bağ tablosu 
     69                String bagTablosu = Cevir.vt(Cevir.isim(cokluAlandakiNesneSinifi.getName()));//gerçek bağ tablosu 
    7070                String bagAlani = Cevir.vt((String)wr.getPropertyValue(alanAdi+".bagAlani")); //YAP: bunu vermeden de varsayılan birşey yapsın 
    7171                fromCumlesi.append(" left join "+bagTablosu+" "+bagTablosuDigerAd); 
    … …  
    9393    public String secmeSorgusuUret(Set baglar, Class nesneSinifi){ 
    9494        //long t1 = System.currentTimeMillis(); 
    95         String nesneAdi = nesneSinifi.getSimpleName(); 
     95        String nesneAdi = Cevir.isim(nesneSinifi.getName()); 
    9696        String tabloAdi = Cevir.vt(nesneAdi); 
    9797        StringBuffer selectCumlesi = new StringBuffer("select "); 
    … …  
    108108    public String saymaSorgusuUret(Set baglar, Class nesneSinifi){ 
    109109        //long t1 = System.currentTimeMillis(); 
    110         String nesneAdi = nesneSinifi.getSimpleName(); 
     110        String nesneAdi = Cevir.isim(nesneSinifi.getName()); 
    111111        String tabloAdi = Cevir.vt(nesneAdi); 
    112112        StringBuffer selectCumlesi = new StringBuffer(); 
    … …  
    123123    public String guncellemeSorgusuUret(Object nesne){ 
    124124        BeanWrapper wr = new BeanWrapperImpl(nesne); 
    125         String nesneAdi = nesne.getClass().getSimpleName(); 
     125        String nesneAdi = Cevir.isim(nesne.getClass().getName()); 
    126126        String tabloAdi = Cevir.vt(nesneAdi); 
    127127        StringBuffer sorgu; 

  • trunk/fmgVen/src/net/fmg/ven/Ven.java

    r22 r26  
    4848        Set baglar = new HashSet(); 
    4949        kullanimlar.put(kullanimNo,baglar); 
    50         baglar.add(nesneSinifi.getSimpleName()); 
     50        baglar.add(Cevir.isim(nesneSinifi.getName())); 
    5151         
    5252        String sorgu = uretici.secmeSorgusuUret(baglar, nesneSinifi); 
    … …  
    111111    public Object nesneAl(Class nesneSinifi, Integer no, Set baglar){ 
    112112        String sorgu = uretici.secmeSorgusuUret(baglar, nesneSinifi); 
    113         Olcut olcut = new Olcut().ekle("and "+Cevir.vt(nesneSinifi.getSimpleName())+".no = :___no").ekle("___no",no); 
     113        Olcut olcut = new Olcut().ekle("and "+Cevir.vt(Cevir.isim(nesneSinifi.getName()))+".no = :___no").ekle("___no",no); 
    114114        sorgu += " where 1=1"+olcut.olcutleriAl(); 
    115115        if(hataAyiklama) System.out.println("SQL: "+sorgu); 
    … …  
    127127    public Object nesneAl(Class nesneSinifi, Integer no, Set baglar, Olcut olcut){ 
    128128        String sorgu = uretici.secmeSorgusuUret(baglar, nesneSinifi); 
    129         sorgu += " where 1=1 and "+Cevir.vt(nesneSinifi.getSimpleName())+".no = :___no "+olcut.olcutleriAl(); //No diğer ölçütlerden önce gelmeli order-limit için 
     129        sorgu += " where 1=1 and "+Cevir.vt(Cevir.isim(nesneSinifi.getName()))+".no = :___no "+olcut.olcutleriAl(); //No diğer ölçütlerden önce gelmeli order-limit için 
    130130        olcut.ekle("___no",no); 
    131131        if(hataAyiklama) System.out.println("SQL: "+sorgu); 
    … …  
    145145        BeanWrapper wr = new BeanWrapperImpl(nesne); 
    146146        if(wr.getPropertyValue("no")==null){             
    147             wr.setPropertyValue("no",new Integer(sablon.queryForInt("select currval('"+Cevir.vt(nesne.getClass().getSimpleName())+"_no')", new HashMap()))); 
     147            wr.setPropertyValue("no",new Integer(sablon.queryForInt("select currval('"+Cevir.vt(Cevir.isim(nesne.getClass().getName()))+"_no')", new HashMap()))); 
    148148        } 
    149149    } 
    150150     
    151151    public void nesneSil(Integer no, Class nesneSinifi){ 
    152         String sorgu = "delete from "+Cevir.vt(nesneSinifi.getSimpleName())+" where no = :no ;"; 
     152        String sorgu = "delete from "+Cevir.vt(Cevir.isim(nesneSinifi.getName()))+" where no = :no ;"; 
    153153        Map parametreler = new HashMap(2); 
    154154        parametreler.put("no",no); 

  • trunk/fmgVen/src/net/fmg/ven/arac/Cevir.java

    r22 r26  
    3535        return sonuc.toString(); 
    3636    } 
     37 
     38    public static String isim(String isim) { 
     39        int i = isim.lastIndexOf("."); 
     40        if (i < 0) return isim; 
     41        return isim.substring(i + 1); 
     42    } 
    3743     
    3844} 
Note: See TracChangeset for help on using the changeset viewer.