环境要求

导入好Hibernate相关jar包，

并且对每一个表都生成了POJO类！

增加数据库记录

表结构如下：

这里使用Hibernate生成的POJO类如下：

Student.java

package my.db;import java.util.Date;/*** Student entity. @author MyEclipse Persistence Tools*/public class Student implements java.io.Serializable {// Fieldsprivate Integer id;private String name;private String phone;private Date birthday;// Constructors/** default constructor */public Student() {}/** full constructor */public Student(Integer id, String name, String phone, Date birthday) {this.id = id;this.name = name;this.phone = phone;this.birthday = birthday;}// Property accessorspublic Integer getId() {return this.id;}public void setId(Integer id) {this.id = id;}public String getName() {return this.name;}public void setName(String name) {this.name = name;}public String getPhone() {return this.phone;}public void setPhone(String phone) {this.phone = phone;}public Date getBirthday() {return this.birthday;}public void setBirthday(Date birthday) {this.birthday = birthday;}}

Example.java

package my.db;/*** Example entity. @author MyEclipse Persistence Tools*/public class Example implements java.io.Serializable {// Fieldsprivate Long id;private String author;private String title;// Constructors/** default constructor */public Example() {}/** full constructor */public Example(String author, String title) {this.author = author;this.title = title;}// Property accessorspublic Long getId() {return this.id;}public void setId(Long id) {this.id = id;}public String getAuthor() {return this.author;}public void setAuthor(String author) {this.author = author;}public String getTitle() {return this.title;}public void setTitle(String title) {this.title = title;}}

关键的添加数据如下：

Test.java

package my.db;import java.text.SimpleDateFormat;
import org.hibernate.Session;
import org.hibernate.Transaction;public class Test {/*** @param args*/public static void main(String[] args) {Session dbss = null;try{SimpleDateFormat sdf = new SimpleDateFormat("yyyy-mm-dd");Student row = new Student();row.setId(201602);row.setName("小明");row.setPhone("18888888888");row.setBirthday(sdf.parse("1888-8-8"));Example re = new Example();re.setAuthor("小明");re.setTitle("装逼指南");/*连接数据库*/dbss = HibernateSessionFactory.getSession();Transaction dbtr = dbss.beginTransaction();dbss.save(row);dbss.save(re);dbtr.commit();System.out.println("数据库生成的小明的ID " + re.getId());System.out.println("测试成功！");}catch(Exception e){System.out.println("出错: " + e.getMessage());e.printStackTrace();}finally{if(dbss!= null) dbss.close();}}}

运行截图如下：

表内容如下：

查询数据

查询数据有3种分别是：

test1：按主键查询

test2：HQL查询 (Hibernate Query Language)

test3：Native SQL 查询

源码如下：

package my.db;import java.util.List;
import org.hibernate.Session;
import org.hibernate.Transaction;public class Test {public static void test1(){Session dbss = null;try{//连接数据库dbss = HibernateSessionFactory.getSession();Integer rowid = new Integer(201602);Student row = (Student)dbss.get(Student.class, rowid);if(row == null){System.out.println("找不到记录！");}else{System.out.println("姓名:" + row.getName() + ",电话:" + row.getPhone());}}catch(Exception e){System.out.println("出错：" + e.getMessage());e.printStackTrace();}finally{if(dbss != null)dbss.close();}}public static void test2(){Session dbss = null;try{//连接数据库dbss = HibernateSessionFactory.getSession();String hql = "from my.db.Student where id > 201601";List<Student> results = dbss.createQuery(hql).list();if(results.size() == 0){System.out.println("找不到记录！");}else{for(Student row: results){System.out.println("姓名:" + row.getName() + ",电话:" + row.getPhone());}}}catch(Exception e){System.out.println("出错: " + e.getMessage());e.printStackTrace();}finally{if(dbss != null)dbss.close();}}public static void test3(){Session dbss = null;try{dbss = HibernateSessionFactory.getSession();String sql = "SELECT * FROM testwebdb.student";List<Object[]> results = dbss.createSQLQuery(sql).list();for(Object[] row : results){Integer id = Integer.valueOf( row[0].toString() );String  name = row[1].toString();String  phone = row[2].toString();String  brithday = row[3].toString(); // System.out.println("学号" + id + "姓名:" + name + ",电话:" + phone + ",生日" + brithday);}}catch(Exception e){System.out.println("出错: " + e.getMessage());e.printStackTrace();}finally{if (dbss != null)dbss.close();}}public static void main(String[] args) {//test1();//test2();//test3();}}

修改数据库记录

修改数据有3种分别是：

test1：按主键查询

test2：HQL查询 (Hibernate Query Language)

test3：Native SQL 查询

源码如下：

package my.db;import java.util.List;
import org.hibernate.Session;
import org.hibernate.Transaction;public class Test {public static void test1(){Session dbss = null;try{dbss = HibernateSessionFactory.getSession();Integer rowid = new Integer(201602);Student row = (Student)dbss.get(Student.class, rowid);if(row != null){row.setPhone("16666666666");//保存到数据Transaction dbtr = dbss.beginTransaction();dbss.update(row);dbtr.commit();}}catch(Exception e){System.out.println("出错: " + e.getMessage());e.printStackTrace();}finally{if(dbss != null)dbss.close();}}public static void test2(){Session dbss = null;try{dbss = HibernateSessionFactory.getSession();Transaction dbtr = dbss.beginTransaction();String hql = "UPDATE Student SET phone='12233330000' WHERE id='201602'";int rowsAffected = dbss.createQuery(hql).executeUpdate();System.out.print(rowsAffected + " rows affected.");dbtr.commit();}catch(Exception e){System.out.println("出错: " + e.getMessage());e.printStackTrace();}finally{if(dbss != null)dbss.close();}}public static void test3(){Session dbss = null;try{/* 连接数据库 */dbss = HibernateSessionFactory.getSession();// 构造一个普通的SQL语句Transaction dbtr = dbss.beginTransaction();String sql = "UPDATE student SET `phone`='13355550000' WHERE id='201601' ";int rowsAffected = dbss.createSQLQuery(sql).executeUpdate();           System.out.println(rowsAffected + " rows affected.");}catch(Exception e){System.out.println("出错: " + e.getMessage());e.printStackTrace();}finally{if(dbss != null)dbss.close();}}public static void main(String[] args) {//test1();//test2();test3();}}

删除数据库记录

删除数据有3种分别是：

test1：按主键查询

test2：HQL查询 (Hibernate Query Language)

test3：Native SQL 查询

源码如下：

package my.db;import java.util.List;
import org.hibernate.Session;
import org.hibernate.Transaction;public class Test {public static void test1(){Session dbss = null;try{dbss = HibernateSessionFactory.getSession();Integer rowid = new Integer(201601);Student row = (Student)dbss.get(Student.class, rowid);if(row != null){Transaction dbtr = dbss.beginTransaction(); dbss.delete(row);dbtr.commit();}}catch(Exception e){System.out.println("出错: " + e.getMessage());e.printStackTrace();}finally{if(dbss != null)dbss.close();}}public static void test2(){Session dbss = null;try{dbss = HibernateSessionFactory.getSession();Transaction dbtr = dbss.beginTransaction();String hql = "delete from Student where id='201602' ";int rowsAffected = dbss.createQuery(hql).executeUpdate();          System.out.println(rowsAffected + " rows affected.");dbtr.commit();}catch(Exception e){System.out.println("出错: " + e.getMessage());e.printStackTrace();}finally{if(dbss != null)dbss.close();}}public static void test3(){Session dbss = null;try{/* 连接数据库 */dbss = HibernateSessionFactory.getSession();// 构造一个普通的SQL语句Transaction dbtr = dbss.beginTransaction();String sql = "DELETE FROM `student` WHERE id='201603' ";int rowsAffected = dbss.createSQLQuery(sql).executeUpdate();          System.out.println(rowsAffected + " rows affected.");dbtr.commit();}catch(Exception e){System.out.println("出错: " + e.getMessage());e.printStackTrace();}finally{if(dbss != null)dbss.close();}}public static void main(String[] args) {//test1();//test2();test3();}}

Java工作笔记-使用Hibernate连接mysql数据库并进行增、删、改、查！相关推荐

Hibernate连接mysql数据库并自动创建表
天才第一步,雀氏纸尿裤,Hibernate第一步,连接数据库. Hibernate是一个开放源代码的对象关系映射框架,它对JDBC进行了非常轻量级的对象封装,它将POJO与数据库表建立映射关系,是一个 ...
jaba窗体连接mysql增删改查_知识实现——Java使用jdbc连接MySql数据库，实现增删改查...
Java使用jdbc连接MySql数据库,实现增删改查首先,导入MySql连接数据库的jar包,我用的是 mysql连接jar包 DB类,用于获得数据库连接 import java.sql.Driv ...
python数据库教程_Python连接mysql数据库及简单增删改查操作示例代码
1.安装pymysql 进入cmd,输入 pip install pymysql: 2.数据库建表在数据库中,建立一个简单的表,如图: 3.简单操作 3.1查询操作 #coding=utf-8 #连 ...
python操作数据库教程_Python连接mysql数据库及简单增删改查操作示例代码
1.安装pymysql 进入cmd,输入 pip install pymysql: 2.数据库建表在数据库中,建立一个简单的表,如图: 3.简单操作 3.1查询操作 #coding=utf-8 #连 ...
hibernate连接MySQL数据库
hibernate最基本的数据库连接,使用mysql. 见一个java工程,见一个包名为"book", 在book的包下加一个java类Book.java,其代码如下: ...
mysql java驱动 ibm_Java 通过JDBC连接Mysql数据库
JDBC(java Data Base Connectivity,Java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口 ...
使用Java语言开发工具idea连接MySQL数据库的基本步骤及操作实例
Java连接MySQL数据库并进行一些基本操作以及导入jar包的两种方式其实,任何开发工具连接数据库无非就是三步:1.安装驱动.2.加载驱动,创建连接对象.3.创建对象操作游标.4.游标调用函数完成 ...
hibernate连接mysql数据库步骤_Hibernate (操作步骤)
在java工程里导入Hibernate架包: 在添加数据库架包如: Hibernate开发步骤: 1.Eclipse下创建Hibernate配置文件(需要tools插件) new---->oth ...
数据库工作笔记009---Centos中导出mysql数据库
JAVA技术交流QQ群:170933152 首先linux 下查看mysql相关目录 root@ubuntu14:~# whereis mysql mysql: /usr/bin/mysql---- ...

Java工作笔记-使用Hibernate连接mysql数据库并进行增、删、改、查！

环境要求

增加数据库记录

查询数据

修改数据库记录

删除数据库记录

Java工作笔记-使用Hibernate连接mysql数据库并进行增、删、改、查！相关推荐

最新文章

热门文章