Hibernate框架简介(二)基本使用增、删、改、查

<?xml version='1.0' encoding='utf-8'?>
<!DOCTYPE hibernate-configuration PUBLIC
"-//Hibernate/Hibernate Configuration DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"><hibernate-configuration> <session-factory> <!-- Database connection settings -->
<!-- 数据库驱动 不同的数据库不一样-->
<property name="connection.driver_class">oracle.jdbc.driver.OracleDriver</property>
<!-- 数据库访问url 不同的数据库不一样-->
<property name="connection.url">jdbc:oracle:thin:@localhost:1521:orcl</property>
<!-- 数据库连接用户名 -->
<property name="connection.username">sa</property>
<!--数据库连接用户名的密码 -->
<property name="connection.password"></property> <!-- JDBC connection pool (use the built-in) -->
<!--数据库连接池默认连接数量 -->
<property name="connection.pool_size">2</property> <!-- SQL dialect -->
<!--方言，不同的数据不同的版都有所不同 -->
<property name="dialect">org.hibernate.dialect.HSQLDialect</property> <!-- Enable Hibernate's current session context -->
<!-- Session设置 -->
<property name="current_session_context_class">org.hibernate.context.ManagedSessionContext</property> <!-- Disable the second-level cache -->
<!--二级缓存 -->
<property name="cache.provider_class">org.hibernate.cache.NoCacheProvider</property> <!-- Echo all executed SQL to stdout -->
<!-- 在执行数据操作时，是不是在控制台显示SQL语句，true为显示 -->
<property name="show_sql">true</property> <!-- Drop and re-create the database schema on startup -->
<!--根据数据库表得到类，根据类到表 -->
<property name="hbm2ddl.auto">create</property>
<!--对类的配置文件映射 -->
<mapping resource="org/hibernate/tutorial/domain/Event.hbm.xml"/>
<mapping resource="org/hibernate/tutorial/domain/Person.hbm.xml"/> </session-factory></hibernate-configuration>

<?xml version='1.0' encoding='utf-8'?>
<!DOCTYPE hibernate-configuration PUBLIC
"-//Hibernate/Hibernate Configuration DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"><hibernate-configuration> <session-factory> <!-- Database connection settings -->
<!-- 数据库驱动 不同的数据库不一样-->
<property name="connection.driver_class">oracle.jdbc.driver.OracleDriver</property>
<!-- 数据库访问url 不同的数据库不一样-->
<property name="connection.url">jdbc:oracle:thin:@localhost:1521:orcl</property>
<!-- 数据库连接用户名 -->
<property name="connection.username">accp</property>
<!--数据库连接用户名的密码 -->
<property name="connection.password">accp</property> </session-factory></hibernate-configuration>

create table login
(
username varchar2(20) primary key,
password varchar2(20)
);

package com.pb.entity;
/*
* 登录实体类
*/
public class Login {
private String username;
private String password; public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}}

<?xml version='1.0' encoding='utf-8'?>
<!-- 这里与hibernate.cfg.xml配置文件不一样注意 -->
<!DOCTYPE hibernate-mapping PUBLIC
"-//Hibernate/Hibernate Configuration DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd"> <!-- 这里与hibernate.cfg.xml配置文件不一样注意 --><hibernate-mapping>
<!--类名和数据库中的表名相对应 哪个用户 -->
<class name="com.pb.entity.Login" table="LOGIN" schema="accp">
<!-- id代表主键 column列表 type代表数据类型-->
<!-- 类中的属性 -->
<id name="username" type="java.lang.String">
<!-- 表中哪一个字段或者是列名 -->
<column name="USERNAME" length="20" />
<!--生成的方式 assigned代表由外部外部程序负责生成，在 save() 之前必须指定一个-->
<!-- native由hibernate根据使用的数据库自行判断采用identity、hilo、sequence其中一种作为主键生成方式，灵活性很强。如果能支持identity则使用identity，如果支持sequence则使用sequence。-->
<generator class="assigned" />
</id>
<!-- 密码段设置 -->
<!--类中的名字和数据类型 -->
<property name="password" type="java.lang.String">
<!-- 表中的字段名，长度可心不要，是不为空true为不能为空,false是可以为空 -->
<column name="PASSWORD" length="20" not-null="true"/>
</property>
<!--如果还有其它的属性，设置方式与password一样设置 -->
</class>
</hibernate-mapping>

<?xml version='1.0' encoding='utf-8'?>
<!DOCTYPE hibernate-configuration PUBLIC
"-//Hibernate/Hibernate Configuration DTD 3.0//EN"
"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"><hibernate-configuration> <session-factory> <!-- Database connection settings -->
<!-- 数据库驱动 不同的数据库不一样-->
<property name="connection.driver_class">oracle.jdbc.driver.OracleDriver</property>
<!-- 数据库访问url 不同的数据库不一样-->
<property name="connection.url">jdbc:oracle:thin:@localhost:1521:orcl</property>
<!-- 数据库连接用户名 -->
<property name="connection.username">accp</property>
<!--数据库连接用户名的密码 -->
<property name="connection.password">accp</property>
<!--为实体类配置文件添加映射 -->
<mapping resource="com/pb/entity/Login.hbm.xml"/>
</session-factory></hibernate-configuration>

package com.pb.until;import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;public class HibernateUtil { private static final SessionFactory sessionFactory; static {
try {
// Create the SessionFactory from hibernate.cfg.xml
sessionFactory = new Configuration().configure().buildSessionFactory();
} catch (Throwable ex) {
// Make sure you log the exception, as it might be swallowed
System.err.println("Initial SessionFactory creation failed." + ex);
throw new ExceptionInInitializerError(ex);
}
} public static SessionFactory getSessionFactory() {
return sessionFactory;
}}

package com.pb.until;import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.hibernate.cfg.Configuration;/**
* Configures and provides access to Hibernate sessions, tied to the
* current thread of execution. Follows the Thread Local Session
* pattern, see {@link http://hibernate.org/42.html }.
*/
public class HibernateSessionFactory { /**
* Location of hibernate.cfg.xml file.
* Location should be on the classpath as Hibernate uses
* #resourceAsStream style lookup for its configuration file.
* The default classpath location of the hibernate config file is
* in the default package. Use #setConfigFile() to update
* the location of the configuration file for the current session.
*/
private static String CONFIG_FILE_LOCATION = "/hibernate.cfg.xml";
private static final ThreadLocal<Session> threadLocal = new ThreadLocal<Session>();
private static Configuration configuration = new Configuration();
private static org.hibernate.SessionFactory sessionFactory;
private static String configFile = CONFIG_FILE_LOCATION; static {
try {
configuration.configure(configFile);
sessionFactory = configuration.buildSessionFactory();
} catch (Exception e) {
System.err
.println("%%%% Error Creating SessionFactory %%%%");
e.printStackTrace();
}
}
private HibernateSessionFactory() {
} /**
* Returns the ThreadLocal Session instance. Lazy initialize
* the <code>SessionFactory</code> if needed.
*
* @return Session
* @throws HibernateException
*/
public static Session getSession() throws HibernateException {
Session session = (Session) threadLocal.get(); if (session == null || !session.isOpen()) {
if (sessionFactory == null) {
rebuildSessionFactory();
}
session = (sessionFactory != null) ? sessionFactory.openSession()
: null;
threadLocal.set(session);
} return session;
} /**
* Rebuild hibernate session factory
*
*/
public static void rebuildSessionFactory() {
try {
configuration.configure(configFile);
sessionFactory = configuration.buildSessionFactory();
} catch (Exception e) {
System.err
.println("%%%% Error Creating SessionFactory %%%%");
e.printStackTrace();
}
} /**
* Close the single hibernate session instance.
*
* @throws HibernateException
*/
public static void closeSession() throws HibernateException {
Session session = (Session) threadLocal.get();
threadLocal.set(null); if (session != null) {
session.close();
}
} /**
* return session factory
*
*/
public static org.hibernate.SessionFactory getSessionFactory() {
return sessionFactory;
} /**
* return session factory
*
* session factory will be rebuilded in the next call
*/
public static void setConfigFile(String configFile) {
HibernateSessionFactory.configFile = configFile;
sessionFactory = null;
} /**
* return hibernate configuration
*
*/
public static Configuration getConfiguration() {
return configuration;
}}

Configuration config=new Configuration().configure();

SessionFactory factory=config.buildSessionFactory();

Session session=factory.openSessin();

Transaction tran=session.beginTransaction();

session.save(对象);
session.update(对象);
session.delete(对象);
session.get(主键之类的);

tran.commit();

session.close();

package com.pb.LoginDao;import java.util.List;import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;import com.pb.entity.Login;
import com.pb.until.HibernateSessionFactory;
import com.pb.until.HibernateUtil;public class LoginDao { /*
* 增加
*/
public void save(Login login) {
// 得到Session
Session session = HibernateUtil.getSessionFactory().openSession();
Transaction tran = null;
// 也可以
// Session session=new
// Configuration().configure().buildSessionFactory().openSession();
try {
// 打开事务
tran = session.beginTransaction();
// 执行数据添加
session.save(login);
// 提交事务
tran.commit();
System.out.println("用户信息添加成功");
} catch (HibernateException e) {
// 事务回滚
tran.rollback();
e.printStackTrace();
System.out.println("用户信息添加失败");
} finally {
// 关闭session
session.close();
} } /*
* 修改根据用户名
*/
public void update(Login login) {
// 得到Session
Session session = HibernateUtil.getSessionFactory().openSession();
Transaction tran = null;
// 也可以
// Session session=new
// Configuration().configure().buildSessionFactory().openSession();
try {
// 打开事务
tran = session.beginTransaction();
// 执行数据添加
session.update(login);
// 提交事务
tran.commit();
System.out.println("用户信息修改成功");
} catch (HibernateException e) {
// 事务回滚
tran.rollback();
e.printStackTrace();
System.out.println("用户信息修改失败");
} finally {
// 关闭session
session.close();
}
} /*
* 修改根据用户名修改密码
*/
public void delte(Login login) {
// 得到Session
Session session = HibernateUtil.getSessionFactory().openSession();
Transaction tran = null;
// 也可以
// Session session=new
// Configuration().configure().buildSessionFactory().openSession();
try {
// 打开事务
tran = session.beginTransaction();
// 执行数据添加
session.delete(login);
// 提交事务
tran.commit();
System.out.println("用户信息删除成功");
} catch (HibernateException e) {
// 事务回滚
tran.rollback();
e.printStackTrace();
System.out.println("用户信息删除失败");
} finally {
// 关闭session
session.close();
}
} /*
* 查询一查询全部用户
*/
public List<Login> QueryALL() {
// 使用myeclipse提供的工具类来得到session
Session session = HibernateSessionFactory.getSession();
// 建立查询
Query query = session.createQuery("from Login");
// 查询重到List集合
List<Login> list = query.list();
// 关闭session
session.close();
// 返回结果集合
return list;
} /*
* 查询二 查询指定的用户名的
*/
public Login QueryByName(String username) {
// 使用myeclipse提供的工具类来得到session
Session session = HibernateSessionFactory.getSession();
// 建立查询
Query query = session.createQuery("from Login l where l.username=?");
// 占位
query.setString(0, username); // 查询返回唯一
Login login = (Login) query.uniqueResult();
// 关闭session
session.close();
// 返回结果集合
return login;
} /*
* 查询三，模糊查询
*/
public List<Login> QueryLikeName(String username) {
// 使用myeclipse提供的工具类来得到session
Session session = HibernateSessionFactory.getSession();
// 建立查询
Query query = session
.createQuery("from Login l where l.username like ?");
// 占位
query.setString(0, "%" + username + "%");
// 查询重到List集合
List<Login> list = query.list();
// 关闭session
session.close();
// 返回结果集合
return list;
}}

package com.pb.test;import java.util.List;import com.pb.LoginDao.LoginDao;
import com.pb.entity.Login;public class Test { public static void main(String[] args) {
//声明LoginDao对象
LoginDao loginDao=new LoginDao();
//声明对象并赋初始值
Login login=new Login();
login.setUsername("Jack");
login.setPassword("blue");
//执行添加
loginDao.save(login);
//执行修改
login.setUsername("Jack");
login.setPassword("while");
loginDao.update(login);
//执行删除
loginDao.delte(login); System.out.println("=========查询全部========");
//查询全部
List<Login> list=loginDao.QueryALL();
for (Login log : list) {
System.out.println("用户名:"+log.getUsername()+" 密码："+log.getPassword());
} System.out.println("=========精确查询========");
//查询一个用户
Login lg=loginDao.QueryByName("ffff");
if(lg!=null){
System.out.println("用户名："+lg.getUsername()+" 密码:"+lg.getPassword());
}else{
System.out.println("没有此用户");
}
System.out.println("=========模糊查询========");
//模糊查询
List<Login> likelist=loginDao.QueryLikeName("t");
for (Login lo : likelist) {
System.out.println("用户名:"+ lo.getUsername()+" 密码："+ lo.getPassword());
}
}}