jtdaoexample.java

Java Pattern Oriented Framework (Jt) 是为了实现Java快速开发的面向模式的框架。

package Jt.examples;

import java.util.Date;
import java.util.List;

import Jt.JtFactory;
import Jt.JtMessage;
import Jt.JtObject;
import Jt.DAO.JtDAOAdapter;
import Jt.DAO.JtDAOStrategy;
import Jt.examples.hibernate.Member;


/**
  * Hibernate (DAO) example. It illustrates the use of the Hibernate Adapter.
  */

public class JtDAOExample {
    
    
    public static void main(String[] args) {

        JtFactory main = new JtFactory ();
        JtMessage msg;
        JtDAOStrategy adapter;
        String emailId = "[e-mail]"; // Key
        int i;
        Member mem;
        List members;

        
        // Create the DAO strategy adapter

        adapter = (JtDAOStrategy) main.createObject (JtDAOStrategy.JtCLASS_NAME);

        //adapter.setConcreteStrategyClassName("Jt.hibernate.JtHibernateAdapter");
        

        // Member object
        
        mem = new Member ();
        mem.setEmail(emailId);
        mem.setFirstname("John");
        mem.setLastname("Daw");
        mem.setTstamp (new Date ());
        mem.setStatus(1);
     
        
        // Insert object
        
        msg = new JtMessage (JtDAOAdapter.JtCREATE);
        msg.setMsgContent(mem);
        main.sendMessage (adapter, msg);
            
        // Check if the object was inserted
        
        msg = new JtMessage (JtDAOAdapter.JtREAD);
        msg.setMsgContent(mem);
        msg.setMsgData (emailId);
        mem = (Member) main.sendMessage (adapter, msg);
        
        if (mem != null) {
            System.out.println("JtINSERT: GO");
            System.out.println("Email:" + mem.getEmail());
            System.out.println("Firstname:" + mem.getFirstname());
            System.out.println("Date:" + mem.getTstamp());  
            /*
            d = new Date ();
            System.out.println("Date:" + d);
            mem.setTstamp (d);
            d = mem.getTstamp();
            System.out.println("Date:" + d);
            */
            
        } else
            System.out.println("JtINSERT: FAIL");           
        
     
        // Update the object

        if (mem != null)
            mem.setFirstname("Jane");
        msg = new JtMessage (JtDAOAdapter.JtUPDATE);
        msg.setMsgContent(mem);
        main.sendMessage (adapter, msg);

        
        // Check that the object was updated
        
        msg.setMsgId (JtDAOAdapter.JtREAD);
        msg.setMsgContent(mem);
        msg.setMsgData (emailId);
        mem = (Member) main.sendMessage (adapter, msg);
        
        if (mem != null) {          
            if ("jane".equals (mem.getEmail()))
                System.out.println("JtUPDATE: GO");               
            else 
                System.out.println("JtUPDATE: GO");
        } else
            System.out.println("JtUPDATE: FAIL");         
            
           
        mem = new Member ();
        mem.setEmail(emailId);
        
        // Delete the object

        msg = new JtMessage (JtDAOAdapter.JtDELETE);   
        msg.setMsgContent(mem);
        //msg.setMsgData(emailId);
        main.sendMessage (adapter, msg); 
 
 
        // Check that the object was deleted
        
        msg.setMsgId (JtDAOAdapter.JtREAD);
        msg.setMsgContent(new Member ());
        msg.setMsgData (emailId);
        mem = (Member) main.sendMessage (adapter, msg);
 
        
        if (mem == null) {           
            System.out.println("JtDELETE: GO");
        } else
            System.out.println("JtDELETE: FAIL");         
                      
        
        // Execute a SQL query
      
        msg.setMsgId (JtDAOAdapter.JtEXECUTE_QUERY);
        msg.setMsgContent("select * from roster");
        msg.setMsgData(new Member ());
        members = (List) main.sendMessage (adapter, msg);
        
        
        if (members != null) {
            System.out.println("count:" + members.size());
            for (i = 0; i < members.size(); i++) {

                Member theMember = (Member) members.get(i);
                System.out.println("Email: " + theMember.getEmail() +
                                   "\nName: " + theMember.getFirstname());
                System.out.println("Date: " + theMember.getTstamp());
            }
        }
      
        // Send a JtREMOVE message to the Hibernate adapter.
        // This closes the session and performs a cleanup (DB connection).
        
        main.sendMessage (adapter, new JtMessage (JtObject.JtREMOVE));
     /*     
        //msg.setMsgId (JtDAOAdapter.JtEXECUTE_QUERY);
        //msg.setMsgContent("select * from history");
        //msg.setMsgData(new History ());        
      */  
      }
}