小学生之Hibernate插入数据修改数据使用数据库默认值的实现

首页 > 代码库 > 小学生之Hibernate插入数据修改数据使用数据库默认值的实现

小学生之Hibernate插入数据修改数据使用数据库默认值的实现

2024-09-02 23:37:14 220人阅读

最近在写一个案例,定时任务对数据库进行更新操作,废话不多说,上代码:

 1 @Component("taskJob")
 2 public class TaskJob extends HibernateDaoSupport {
 3     
 4     @Resource
 5     private SessionFactory sessionFactory;
 6 
 7     @PostConstruct
 8     public void init() {
 9         setSessionFactory(sessionFactory);
10     }
11     
12     @Scheduled(cron = "0 0/1 * * * ?")
13     @Transactional
14     public void jobl() throws InterruptedException {
15         System.out.println("任务开始执行....");
16         this.getHibernateTemplate().execute(new HibernateCallback() {
17 
18             public Object doInHibernate(Session session)
19                     throws HibernateException {
20                 session.createSQLQuery("truncate table tm_org").executeUpdate();
21                 return null;
22             }
23         });
24         System.out.println("删除完毕........");
25         Thread.sleep(1000);
26         final File file = new File("C:\\Users\\lhq\\Desktop\\T1018.txt");
27         BufferedReader reader = null;
28         try {
29             System.out.println("以行为单位读取文件内容，一次读一整行：");
30             reader = new BufferedReader(new InputStreamReader(new FileInputStream(file),"UTF-8"));
31             String tempString = null;
32          // 一次读入一行，直到读入null为文件结束
33             while ((tempString = reader.readLine()) != null) {
34                 final String[] split = tempString.split("\\s+");
35                 Org org = new Org();
36                 org.setOrgCode(split[0]);
37                 org.setOrgName(split[1]);
38 //                org.setStatus("0");
39                 if (split.length>3) {
40                     org.setUpOrg(split[3]);
41                 }
42                 org.setCreator("superuser");
43                 this.getHibernateTemplate().persist(org);
44                 
45             }
46             reader.close();
47             
48         } catch (final IOException e) {
49             e.printStackTrace();
50         } finally {
51             if (reader != null) {
52                 try {
53                     reader.close();
54                 } catch (final IOException e) {
55                 }
56             }
57         }
58     }
59 }