[Neuclear-develop] neuclear-commons/src/java/org/neuclear/commons/sql/entities ColumnDefinition.java,NONE,1.1 DataColumnDefinition.java,NONE,1.1 Entity.java,NONE,1.1 EntityModel.java,NONE,1.1 ReferenceDefinition.java,NONE,1.1

[<pe...@us...>]

Update of /cvsroot/neuclear/neuclear-commons/src/java/org/neuclear/commons/sql/entities
In directory sc8-pr-cvs1:/tmp/cvs-serv23495/src/java/org/neuclear/commons/sql/entities

Added Files:
	ColumnDefinition.java DataColumnDefinition.java Entity.java 
	EntityModel.java ReferenceDefinition.java 
Log Message:
Created a kind of poor man's version of ofbiz.org's EntityEngine. It doesnt use xml to configure it, but code.
Should mainly be used to create tables. Can also insert rows, but hasnt been thoroughly tested. 
At some point I will improve that part and add some kind of smart querying engine to it. Similar to EntityEngine. But I dont
need that myself right now.
SQLLedger now uses this to create its tables. It is not fully working yet, but will be shortly.

--- NEW FILE: ColumnDefinition.java ---
package org.neuclear.commons.sql.entities;

/*
NeuClear Distributed Transaction Clearing Platform
(C) 2003 Pelle Braendgaard

This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.

This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

$Id: ColumnDefinition.java,v 1.1 2003/12/24 00:25:40 pelle Exp $
$Log: ColumnDefinition.java,v $
Revision 1.1  2003/12/24 00:25:40  pelle
Created a kind of poor man's version of ofbiz.org's EntityEngine. It doesnt use xml to configure it, but code.
Should mainly be used to create tables. Can also insert rows, but hasnt been thoroughly tested.
At some point I will improve that part and add some kind of smart querying engine to it. Similar to EntityEngine. But I dont
need that myself right now.
SQLLedger now uses this to create its tables. It is not fully working yet, but will be shortly.

*/

/**
 * User: pelleb
 * Date: Dec 23, 2003
 * Time: 2:15:18 PM
 */
public abstract class ColumnDefinition {
    protected ColumnDefinition(EntityModel table, String name) {
        this.model=table;
        this.name=name;
    }
    public abstract String createDDL();

    public final EntityModel getModel(){
        return model;
    }

    public String getName() {
        return name;
    }

    public int hashCode() {
        return (getClass().hashCode()+name.hashCode())/2;    //To change body of overriden methods use Options | File Templates.
    }

    public boolean equals(Object object) {
        if (object==this)
            return true;
        if (!object.getClass().equals(this.getClass()))
           return false;
        final ColumnDefinition col2 = ((ColumnDefinition)object);
        return getModel().equals(col2.getModel())&&getName().equals(col2.getName());
    }

    private final String name;
    private final EntityModel model;
    public static final int FIELD_URI=0;
    public static final int FIELD_COMMENT=1;
    public static final int FIELD_MONEY=2;
    public static final int FIELD_TIMESTAMP=3;
    public static final int FIELD_ID=4;
    public static final int FIELD_BOOLEAN=5;


}

--- NEW FILE: DataColumnDefinition.java ---
package org.neuclear.commons.sql.entities;

/*
NeuClear Distributed Transaction Clearing Platform
(C) 2003 Pelle Braendgaard

This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.

This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

$Id: DataColumnDefinition.java,v 1.1 2003/12/24 00:25:40 pelle Exp $
$Log: DataColumnDefinition.java,v $
Revision 1.1  2003/12/24 00:25:40  pelle
Created a kind of poor man's version of ofbiz.org's EntityEngine. It doesnt use xml to configure it, but code.
Should mainly be used to create tables. Can also insert rows, but hasnt been thoroughly tested.
At some point I will improve that part and add some kind of smart querying engine to it. Similar to EntityEngine. But I dont
need that myself right now.
SQLLedger now uses this to create its tables. It is not fully working yet, but will be shortly.

*/

/**
 * User: pelleb
 * Date: Dec 23, 2003
 * Time: 2:31:13 PM
 */
public class DataColumnDefinition  extends ColumnDefinition{
    public DataColumnDefinition(EntityModel table, String name, int type) {
        super(table,name);
        this.type = type;
    }

    public final String createDDL(){
        return getName()+" "+getDefinition();
    }

    protected String getDefinition() {
        switch(type){
            case FIELD_COMMENT:
                return "VARCHAR(100)";
            case FIELD_MONEY:
                return "DECIMAL";
            case FIELD_TIMESTAMP:
                return "TIMESTAMP";
            case FIELD_ID:
                return "BIGINT";
            case FIELD_BOOLEAN:
                return "TINYINT";
        }
        return "VARCHAR(50)";
    }

    public int getType() {
        return type;
    }

    private final int type;
}

--- NEW FILE: Entity.java ---
package org.neuclear.commons.sql.entities;

/*
NeuClear Distributed Transaction Clearing Platform
(C) 2003 Pelle Braendgaard

This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.

This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

$Id: Entity.java,v 1.1 2003/12/24 00:25:40 pelle Exp $
$Log: Entity.java,v $
Revision 1.1  2003/12/24 00:25:40  pelle
Created a kind of poor man's version of ofbiz.org's EntityEngine. It doesnt use xml to configure it, but code.
Should mainly be used to create tables. Can also insert rows, but hasnt been thoroughly tested.
At some point I will improve that part and add some kind of smart querying engine to it. Similar to EntityEngine. But I dont
need that myself right now.
SQLLedger now uses this to create its tables. It is not fully working yet, but will be shortly.

*/

/**
 * User: pelleb
 * Date: Dec 23, 2003
 * Time: 4:38:23 PM
 */
public class Entity {
    public Entity(EntityModel model,String id,Object[] data) {
        this.model = model;
        this.data=data;
        this.id=id;
    }
    public String getID(){
        return id;
    }

    public Object[] getData() {
        return data;
    }

    public EntityModel getModel() {
        return model;
    }


    private final EntityModel model;
    private final Object data[];
    private final String id;
}

--- NEW FILE: EntityModel.java ---
package org.neuclear.commons.sql.entities;

import java.util.*;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Timestamp;

/*
NeuClear Distributed Transaction Clearing Platform
(C) 2003 Pelle Braendgaard

This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.

This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

$Id: EntityModel.java,v 1.1 2003/12/24 00:25:40 pelle Exp $
$Log: EntityModel.java,v $
Revision 1.1  2003/12/24 00:25:40  pelle
Created a kind of poor man's version of ofbiz.org's EntityEngine. It doesnt use xml to configure it, but code.
Should mainly be used to create tables. Can also insert rows, but hasnt been thoroughly tested.
At some point I will improve that part and add some kind of smart querying engine to it. Similar to EntityEngine. But I dont
need that myself right now.
SQLLedger now uses this to create its tables. It is not fully working yet, but will be shortly.

*/

/**
 * User: pelleb
 * Date: Dec 23, 2003
 * Time: 2:13:21 PM
 */
public final class EntityModel {
    public EntityModel(final String name,String idname,boolean uri){
        columns=new HashMap();
        colseq=new LinkedList();
        foreign=new LinkedList();
        this.name=name;
        id=new DataColumnDefinition(this,idname,uri?ColumnDefinition.FIELD_URI:ColumnDefinition.FIELD_ID);
        addColumn(id);
    }
    public EntityModel(final String name,boolean uri){
        this(name,"id",uri);
    }
    public final void create(Connection con){
        //first lets build all the Dependencies
        for (int i = 0; i < foreign.size(); i++) {
            ReferenceDefinition definition = (ReferenceDefinition) foreign.get(i);
            definition.getRef().create(con);
        }
        System.out.println("Attempting to create: "+getName());
        try {
            PreparedStatement stmt=con.prepareStatement(createDDL());
            stmt.execute();
        } catch (SQLException e) {
            System.out.println(e.getLocalizedMessage());
        }
    }
    public final String createDDL(){
        StringBuffer buf=new StringBuffer("CREATE TABLE ");
        buf.append(name);
        buf.append(" (\n");
        Iterator iter=colseq.iterator();
        while(iter.hasNext()) {
            ColumnDefinition col=(ColumnDefinition)iter.next();
            buf.append(col.createDDL());
            buf.append(",\n");
        }
        iter=foreign.iterator();
        while(iter.hasNext()) {
            ReferenceDefinition col=(ReferenceDefinition)iter.next();
            buf.append("FOREIGN KEY (");
            buf.append(col.getName());
            buf.append(") REFERENCES ");
            buf.append(col.getRef().getName());
            buf.append("(");
            buf.append(col.getRef().getId().getName());
            buf.append(") ON DELETE CASCADE,\n");
//            buf.append("INDEX ");
//            buf.append(col.getName());
//            buf.append("idx (");
//            buf.append(col.getName());
//            buf.append("),\n");
        }
        buf.append("PRIMARY KEY(");
        buf.append(id.getName());
        buf.append(")\n)");
        return buf.toString();
    }

    public final String getName() {
        return name;
    }
    private final ColumnDefinition addColumn(ColumnDefinition col){
        columns.put(col.getName(),col);
        colseq.add(col);
        return col;
    }
    public final DataColumnDefinition addURI(String name){
        return (DataColumnDefinition) addColumn(new DataColumnDefinition(this,name,ColumnDefinition.FIELD_URI));
    }
    public final DataColumnDefinition addURI(){
        return addURI("name");
    }
    public final DataColumnDefinition addMoney(String name){
        return (DataColumnDefinition) addColumn(new DataColumnDefinition(this,name,ColumnDefinition.FIELD_MONEY));
    }
    public final DataColumnDefinition addMoney(){
        return addMoney("amount");
    }
    public final DataColumnDefinition addTimeStamp(String name){
        return (DataColumnDefinition) addColumn(new DataColumnDefinition(this,name,ColumnDefinition.FIELD_TIMESTAMP));
    }
    public final DataColumnDefinition addTimeStamp(){
        return addTimeStamp("created");
    }
    public final DataColumnDefinition addValueTime(){
        return addTimeStamp("valuetime");
    }
    public final DataColumnDefinition addComment(String name){
        return (DataColumnDefinition) addColumn(new DataColumnDefinition(this,name,ColumnDefinition.FIELD_COMMENT));
    }
    public final DataColumnDefinition addComment(){
        return addComment("comment");
    }
    public final DataColumnDefinition addTitle(){
        return addURI("title");
    }
    public final DataColumnDefinition addBoolean(String name){
        return (DataColumnDefinition) addColumn(new DataColumnDefinition(this,name,ColumnDefinition.FIELD_BOOLEAN));
    }
    public final ReferenceDefinition addReference(EntityModel def) {
        ReferenceDefinition ref=new ReferenceDefinition(this,def);
        return addReference(ref);
    }

    private ReferenceDefinition addReference(ReferenceDefinition ref) {
        addColumn(ref);
        foreign.add(ref);
        return ref;
    }

    public final ReferenceDefinition addReference(String name,EntityModel def) {
        return addReference(new ReferenceDefinition(this,def,name));
    }

    public final DataColumnDefinition getId() {
        return id;
    }
    final Entity insertEntity(Connection con,Object data[]) throws SQLException {
        if ((data.length%2==1))//&&(data.length/2<columns.size()))
            throw new SQLException("Incorrect amount of parameters");
        StringBuffer buf=new StringBuffer(22+getName().length()+3*(data.length/2));
        buf.append("INSERT INTO ");
        buf.append(getName());
        buf.append(" (");
        for (int i = 0; i<data.length; i+=2){
            if (i>0)
                buf.append(", ");
            buf.append(data[i]);
        }

        buf.append(") VALUES (");
        for (int i = 0; i<data.length; i+=2){
            if (i>0)
                buf.append(", ");
            buf.append("?");
        }
        buf.append(")");
        PreparedStatement stmt=con.prepareStatement(buf.toString());
        String id=null;
        for (int i = 0; i<(data.length/2); i++){
            int j=i*2;
            ColumnDefinition definition = (ColumnDefinition) columns.get(data[j]);
            if (definition instanceof ReferenceDefinition) {
                ReferenceDefinition ref=(ReferenceDefinition) definition;
                if (data[2*i+1] instanceof Object[]) {
                    Entity refentity=ref.getRef().insertEntity(con,(Object[]) data[j+1]);
                    stmt.setString(i+1,refentity.getID());
                } else {
                    stmt.setString(i+1,data[j+1].toString());
                }
            } else {
                switch (((DataColumnDefinition)definition).getType()) {
                    case ColumnDefinition.FIELD_MONEY:
                        stmt.setDouble(i+1,((Double)data[j+1]).doubleValue());
                        break;
                    case ColumnDefinition.FIELD_TIMESTAMP:
                        stmt.setTimestamp(i+1,((Timestamp)data[j+1]));
                        break;
                    case ColumnDefinition.FIELD_ID:
                        stmt.setLong(i+1,((Long)data[j+1]).longValue());
                        break;
                    case ColumnDefinition.FIELD_BOOLEAN:
                        stmt.setBoolean(i+1,((Boolean)data[j+1]).booleanValue());
                        break;
                    default:
                        stmt.setString(i+1,data[j+1].toString());
                }
                if (getId().getName().equals(data[j]))
                    id=data[j+1].toString();
            }
        }
        stmt.execute();
        return new Entity(this,id,data);
    }
    private final DataColumnDefinition id;
    private final Map columns;
    private final List colseq;

    private final List foreign;
    private final String name;

}

--- NEW FILE: ReferenceDefinition.java ---
package org.neuclear.commons.sql.entities;

/*
NeuClear Distributed Transaction Clearing Platform
(C) 2003 Pelle Braendgaard

This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.

This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

$Id: ReferenceDefinition.java,v 1.1 2003/12/24 00:25:40 pelle Exp $
$Log: ReferenceDefinition.java,v $
Revision 1.1  2003/12/24 00:25:40  pelle
Created a kind of poor man's version of ofbiz.org's EntityEngine. It doesnt use xml to configure it, but code.
Should mainly be used to create tables. Can also insert rows, but hasnt been thoroughly tested.
At some point I will improve that part and add some kind of smart querying engine to it. Similar to EntityEngine. But I dont
need that myself right now.
SQLLedger now uses this to create its tables. It is not fully working yet, but will be shortly.

*/

/**
 * User: pelleb
 * Date: Dec 23, 2003
 * Time: 2:34:09 PM
 */
public class ReferenceDefinition extends ColumnDefinition{
    public ReferenceDefinition(EntityModel table, EntityModel ref){
        this(table,ref,ref.getName()+"id");
    }
    public ReferenceDefinition(EntityModel table, EntityModel ref,String name) {
        super(table,name);
        this.ref = ref;
    }


    public final String createDDL() {
        return getName()+" "+getDefinition();
    }
    private final String getDefinition(){
        if (ref.getId().getType()==ColumnDefinition.FIELD_ID)
            return "INTEGER";
        return "VARCHAR(50)";
    }

    public final EntityModel getRef() {
        return ref;
    }

    private final EntityModel ref;
}