⭐ 欢迎来到虫虫下载站! | 📦 资源下载 📁 资源专辑 ℹ️ 关于我们
⭐ 虫虫下载站

📄 helloworldtest.java

📁 jboss4 + Mysql +ejb3.0 EJB3 简单例子
💻 JAVA
字号:
package com.myejb.test;

import java.util.Properties;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import com.myejb.QL3.QueryDAO;

public class HelloWorldTest{
    Log log = LogFactory.getLog("WANGKU");

    public void test() throws NamingException{
//        double te = 3.4;
//        log.info(Math.round(te));
        Properties props = new Properties();
        props.setProperty("java.naming.factory.initial","org.jnp.interfaces.NamingContextFactory");
        props.setProperty("java.naming.provider.url","localhost:1099");
        props.setProperty("java.naming.factory.url.pkgs","org.jboss.naming");
        
        props.setProperty(Context.SECURITY_PRINCIPAL,"lihuoming");
        props.setProperty(Context.SECURITY_CREDENTIALS,"123456");

        InitialContext ctx;
        ctx = new InitialContext(props);
//        EntityLifecycleDAO dao = (EntityLifecycleDAO)ctx.lookup("EntityLifecycleDAOBean/remote");
//        dao.persist();
//        dao.load();
//        dao.update();
//        dao.remove();
//        //==================195===自定义JNDI采用配置文=======================
//        HelloWord hello = (HelloWord)ctx.lookup("hello/remote");
//        log.info(hello.SayHello("哈哈成功了!"));
//        //====================消息驱动客户端应用=======================
//        TopicConnection cnn = null;
////        QueueSender sender = null;
//        TopicSession sess  = null;
////        Queue queue = null;
//        TopicConnectionFactory factory = (TopicConnectionFactory)ctx.lookup("TopicConnectionFactory");
//        try{
//            cnn = factory.createTopicConnection();
//            sess = cnn.createTopicSession(false,TopicSession.AUTO_ACKNOWLEDGE);
//            Destination destination = (Topic)ctx.lookup("topic/chatTopic1");
//            
//            MessageProducer producer = sess.createProducer(destination);
//            TextMessage msg = sess.createTextMessage("你好,这是我的第一个消息驱动Bean");
//            //sender = sess.createSender(queue);
//            producer.send(msg);
////            sess.close();
////            System.out.println("消息已经发送出去了,你可以到JBoss控制台查看Bean的输出");
//        }catch(JMSException e){
//            // TODO 自动生成 catch 块
//            e.printStackTrace();
//        }finally{
//            try{
//                sess.close();
//                cnn.close();
//            }catch(JMSException e){
//                e.printStackTrace();
//            }
//        }
        
        //=============================实体Bean客户端应用====================================
//        OneToOneDAO dao = (OneToOneDAO)ctx.lookup("OneToOneDAOBean/remote");
//        SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
//        SimpleDateFormat formatter1 = new SimpleDateFormat("MMddhhmmss");
//        String endno = formatter1.format(new Date()).toString();
//        TeacherDAO dao = (TeacherDAO)ctx.lookup("TeacherDAOBean/remote");
        try{
            // EJB3 QL 112
            QueryDAO dao = (QueryDAO)ctx.lookup("QueryDAOBean/remote");
            dao.initdate();
            log.info(dao.executeQuery(3));
            log.info(dao.executeQuery(4));
            log.info(dao.executeQuery(5));
//            dao.insertTeacher("五老师",new String[]{"刘谦","王五","龚利"}); // 添加一个人
//            Teacher teacher = dao.getTeacherByID(new Integer(2));
//            //Person person = dao.getPersonByID(new Integer(1));
//            if(teacher!=null){
//                log.info("编号为1的人员姓名:");
//                log.info(" "+teacher.getTeacherName());
//                Iterator iterator = teacher.getStudents().iterator();
//                while(iterator.hasNext()){
//                    Student student = (Student)iterator.next();
//                    log.info("   他的学生:"+student.getStudentName()+" ");
//                }
//                
//            }else{
//                log.info("没有找到编号为1的人员");
//            }
//            Student student = dao.getStudentByID(new Integer(1));
//            if(student!=null){
//                log.info("============获取编号为1的学生姓名:===========================");
//                log.info("  "+student.getStudentName());
//                Iterator it = student.getTeachers().iterator();
//                while(it.hasNext()){
//                    Teacher tc = (Teacher)it.next();
//                    log.info(" 他的老师:"+tc.getTeacherName());
//                }
//            }else{
//                log.info("没有找到编号为1的学生");
//            }
//            
//            
//            //log.info("======================更新编号为1的人员的姓名为李明,身份证号为33023");
//            //dao.updatePersonInfo(new Integer(1),"李明","33012"+endno);
//            
//            //personDao.update("成龙",1);
////            List result = personDao.queryQL("select p from Person p");
////            for(Object o:result){
////                Person p = (Person)o;
////                System.out.println(p.getName());
////                System.out.println(p.getBirthday());
////                System.out.println(p.getAge());
////            }
////            System.out.println(personDao.getPersonNameById(2));  // 取得personid为1的人
        }catch(Exception e){
            // TODO 自动生成 catch 块
            e.printStackTrace();
        }
//        OrderDao orderDao = (OrderDao)ctx.lookup("OrderDaoBean/remote");
//        orderDao.insertOrders();
//        try{
//            //personDao.insertPerson("神啊",true,(short)26,formatter.parse("2007-1-9")); // 添加一个人
//            //personDao.update("成龙",1);
//            System.out.println("11111111111111");
//            Orders ord = orderDao.getOrdersById(Integer.valueOf(1));
//            List result = orderDao.getAllOrders();
//            System.out.println("22222222222222:"+ord);
//            if(result!=null){
//                Integer orderid = null;
//                for(int i=0;i<result.size();i++){
//                    Orders order = (Orders)result.get(i);
//                    if(order!=null){
//                        if(!order.getOrderid().equals(orderid)){
//                            orderid = order.getOrderid();
//                            log.info("======================订单号:"+order.getOrderid());
//                            Iterator iterator = order.getOrderitems().iterator();
//                            while(iterator.hasNext()){
//                                OrderItem subOrder = (OrderItem)iterator.next();
//                                log.info("订购产品:"+subOrder.getProductname());
//                            }
//                        }
//                    }
//                }
//            }else{
//                log.info("获取不到订单列表");
//            }
//        }catch(Exception e){
//            // TODO 自动生成 catch 块
//            e.printStackTrace();
//        }        
        //HelloChinaRemote hello = (HelloChinaRemote)ctx.lookup("HelloChinaBean2/remote");
        //log.info(hello.sayHello("胖子"));
        //Injection injection = (Injection)ctx.lookup("InjectionBean/remote");
//        TimeService timer = (TimeService)ctx.lookup("TimeServiceBean/remote");
//        timer.scheduleTimer(2000);
//        log.info("定时器已启动,请观察Jboss控制台输出,如果定时器角发10次,便终止定时器。");
//        try{
//
//            // HelloWord hello = (HelloWord)ctx.lookup("HelloWorldBean/remote");
//            Operation operation = (Operation) ctx.lookup("myejb/RemoteOperation");
//            log.info("通过远程接口调用EJB成功");
//            log.info("<br>(通过远程接口调用EJB)相加的结果是:" + operation.Add(1,1));
//        }catch(Exception e){
//            log.info("<br>远程接口调用失败");
//        }
//        log.info("<br>=========================================");
//        try{
//            // 通过本地接口调用EJB
//            LocalOperation a = (LocalOperation) ctx.lookup("myejb/LocalOperation");
//            // log.info("通过本地接口调用EJB成功");
//            log.info("<br>(通过本地接口调用EJB)相加的结果是:" + a.Add(1,1));
//            log.info("<br>调用A.getResult()的结果是:" + a.getResult());
//            LocalOperation b = (LocalOperation) ctx.lookup("myejb/LocalOperation");
//            log.info("<br>(通过本地接口调用EJB)调用B.Add()的结果是:" + b.Add(1,1));
//            log.info("<br>调用B.getResult()的结果是:<font color=red>" + b.getResult()
//                    + "</font>");
//
//        }catch(Exception e){
//            log.info("<br>本地接口调用失败");
//        }
//        try{
//            // 通过本地接口调用EJB
//            MyAccount a = (MyAccount) ctx.lookup("MyAccountBean/remote");
//            // log.info("通过本地接口调用EJB成功");
//            log.info("<br>调用A.Add()的结果是:" + a.Add(1,1));
//            log.info("<br>调用A.getResult()的结果是:" + a.getResult());
//            MyAccount b = (MyAccount) ctx.lookup("MyAccountBean/remote");
//            log.info("<br>调用B.Add()的结果是:" + b.Add(1,1));
//            log.info("<br>调用B.getResult()的结果是:<font color=red>" + b.getResult()+ "</font>");
//
//        }catch(Exception e){
//            log.info("<br>本地接口调用失败");
//        }        
    }

    public static void main(String[] args){
        HelloWorldTest test = new HelloWorldTest();
        try{
            test.test();
        }catch(NamingException e){
            e.printStackTrace();
        }
    }
}

⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -