personserveroperation.java

一款仿msdn聊天程序,用java编写,很好用!

package org.lxh.hibernate.demo07.oper;

import java.util.HashSet;
import java.util.List;

import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.cfg.Configuration;
import org.lxh.hibernate.demo07.pojo.Person;
import org.lxh.hibernate.demo07.pojo.Server;

public class PersonServerOperation {
	private Session session;

	public PersonServerOperation() {
		this.session = new Configuration().configure().buildSessionFactory()
				.openSession();
	}

	public void insert(Person per) {
		this.session.save(per);
		this.session.beginTransaction().commit();
	}

	public void insert(Server ser) {
		this.session.save(ser);
		this.session.beginTransaction().commit();
	}

	public Person queryByPid(String pid) {
		Person p = null;
		String hql = "FROM Person AS p WHERE p.pid=?";
		Query q = this.session.createQuery(hql);
		q.setString(0, pid);
		List all = q.list();
		if (all.size() > 0) {
			p = (Person) all.get(0);
		}
		return p;
	}

	public Server queryBySid(String sid) {
		Server s = null;
		String hql = "FROM Server AS s WHERE s.sid=?";
		Query q = this.session.createQuery(hql);
		q.setString(0, sid);
		List all = q.list();
		if (all.size() > 0) {
			s = (Server) all.get(0);
		}
		return s;
	}
	
	public void deleteByPid(String pid)
	{
		String hql = "DELETE FROM Person WHERE pid=?" ;
		Query q = this.session.createQuery(hql) ;
		q.setString(0,pid) ;
		q.executeUpdate() ;
		this.session.beginTransaction().commit() ;
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		PersonServerOperation pso = new PersonServerOperation();
//		 Person per = new Person() ;
//		 per.setName("lixinghua") ;
//		 per.setAge(30) ;
//		 per.setServers(new HashSet()) ;
//				
//		 Server ser = null ;
//		 ser = new Server() ;
//		 ser.setName("JAVA 服务") ;
//		 per.getServers().add(ser) ;
//				
//		 ser = new Server() ;
//		 ser.setName("JSP 服务") ;
//		 per.getServers().add(ser) ;
//				
//		 ser = new Server() ;
//		 ser.setName("J2EE 服务") ;
//		 per.getServers().add(ser) ;
//				
//		 ser = new Server() ;
//		 ser.setName("框架 服务") ;
//		 per.getServers().add(ser) ;
//				
//		 ser = new Server() ;
//		 ser.setName("Web 服务") ;
//		 per.getServers().add(ser) ;
//				
//		 pso.insert(per) ;

		// Server ser = new Server() ;
		// ser.setName("MLDN JAVA 推广活动") ;
		// ser.setPersons(new HashSet()) ;
		// Person per = null ;
		// per = new Person() ;
		// per.setName("ZhangSan") ;
		// per.setAge(30) ;
		// ser.getPersons().add(per) ;
		//		
		// per = new Person() ;
		// per.setName("LiSi") ;
		// per.setAge(31) ;
		// ser.getPersons().add(per) ;
		//		
		// per = new Person() ;
		// per.setName("WangWu") ;
		// per.setAge(32) ;
		// ser.getPersons().add(per) ;
		//		
		// pso.insert(ser) ;
//		Person p = pso.queryByPid("ff8080811310c124011310c128fb0001");
//		System.out.println(p.getName() + " --> " + p.getAge());
//		System.out.println("所拥有的各种服务：");
//		Iterator iter = p.getServers().iterator();
//		while (iter.hasNext()) {
//			Server s = (Server) iter.next();
//			System.out.println("  |- "+s.getName()) ;
//		}
//		Server s = pso.queryBySid("ff8080811310c4c3011310c4c7640001");
//		System.out.println(s.getName());
//		System.out.println("所参加的人员：");
//		Iterator iter = s.getPersons().iterator();
//		while (iter.hasNext()) {
//			Person p = (Person) iter.next();
//			System.out.println("  |- "+p.getName()+" --> "+p.getAge()) ;
//		}
		pso.deleteByPid("ff8080811310d1f5011310d1f9060001") ;
	}

}