Skip to content

Commit b7c7bf5

Browse files
author
vison.cao
committedJan 8, 2021
tomcat container hibernate ok
embed-tomcat is wrong
1 parent a209baf commit b7c7bf5

File tree

10 files changed

+271
-62
lines changed

10 files changed

+271
-62
lines changed
 

‎pom.xml

+42-3
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,12 @@
5656
<artifactId>tomcat-websocket</artifactId>
5757
<version>${tomcat.version}</version>
5858
</dependency>
59+
<dependency>
60+
<groupId>org.apache.tomcat.embed</groupId>
61+
<artifactId>tomcat-embed-el</artifactId>
62+
<version>${tomcat.version}</version>
63+
<scope>compile</scope>
64+
</dependency>
5965
<dependency>
6066
<groupId>org.reflections</groupId>
6167
<artifactId>reflections</artifactId>
@@ -76,16 +82,49 @@
7682
<dependency>
7783
<groupId>mysql</groupId>
7884
<artifactId>mysql-connector-java</artifactId>
79-
<version>5.1.26</version>
85+
<version>8.0.8-dmr</version>
8086
</dependency>
8187
<!-- https://mvnrepository.com/artifact/org.mybatis/mybatis -->
8288
<dependency>
8389
<groupId>org.mybatis</groupId>
8490
<artifactId>mybatis</artifactId>
8591
<version>3.5.6</version>
8692
</dependency>
87-
88-
93+
<!-- https://mvnrepository.com/artifact/org.hibernate/hibernate-core -->
94+
<dependency>
95+
<groupId>org.hibernate</groupId>
96+
<artifactId>hibernate-core</artifactId>
97+
<version>5.4.27.Final</version>
98+
</dependency>
99+
100+
<dependency>
101+
<groupId>javax.xml.bind</groupId>
102+
<artifactId>jaxb-api</artifactId>
103+
<version>2.3.0</version>
104+
</dependency>
105+
<dependency>
106+
<groupId>com.sun.activation</groupId>
107+
<artifactId>javax.activation</artifactId>
108+
<version>1.2.0</version>
109+
</dependency>
110+
<!-- https://mvnrepository.com/artifact/org.glassfish.jaxb/jaxb-runtime -->
111+
<dependency>
112+
<groupId>org.glassfish.jaxb</groupId>
113+
<artifactId>jaxb-runtime</artifactId>
114+
<version>2.3.3</version>
115+
</dependency>
116+
<!-- https://mvnrepository.com/artifact/antlr/antlr -->
117+
<dependency>
118+
<groupId>antlr</groupId>
119+
<artifactId>antlr</artifactId>
120+
<version>2.7.7</version>
121+
</dependency>
122+
<!-- https://mvnrepository.com/artifact/net.bytebuddy/byte-buddy -->
123+
<dependency>
124+
<groupId>net.bytebuddy</groupId>
125+
<artifactId>byte-buddy</artifactId>
126+
<version>1.10.17</version>
127+
</dependency>
89128

90129
</dependencies>
91130

‎src/main/java/com/vison/webmvc/TestHibernate.java

+40
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
package com.vison.webmvc;
2+
3+
import com.vison.webmvc.entity.User;
4+
import com.vison.webmvc.framework.HibernateLoader;
5+
import org.hibernate.Session;
6+
import org.hibernate.Transaction;
7+
8+
/**
9+
*
10+
* @author vison.cao <visonforcoding@gmail.com>
11+
*/
12+
public class TestHibernate {
13+
14+
/**
15+
* @param args the command line arguments
16+
*/
17+
public static void main(String[] args) {
18+
// TODO code application logic here
19+
Transaction transaction = null;
20+
try (Session session = HibernateLoader.getSessionFactory().openSession()) {
21+
// start a transaction
22+
transaction = session.beginTransaction();
23+
User user = new User();
24+
user.setName("vison");
25+
user.setEmail("visonforcoding@gmail.com");
26+
user.setCountry("赛德克巴莱");
27+
// save the student object
28+
session.save(user);
29+
// commit transaction
30+
transaction.commit();
31+
session.close();
32+
} catch (Exception e) {
33+
if (transaction != null) {
34+
transaction.rollback();
35+
}
36+
e.printStackTrace();
37+
}
38+
}
39+
40+
}

‎src/main/java/com/vison/webmvc/config/DatabaseConfig.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -10,10 +10,10 @@
1010
*/
1111
public class DatabaseConfig {
1212

13-
static String driver = "com.mysql.jdbc.Driver";
14-
static String url = "jdbc:mysql://localhost:3306/db_itdoc?useSSL=false";
15-
static String username = "root";
16-
static String password = "12345678";
13+
public static String driver = "com.mysql.jdbc.Driver";
14+
public static String url = "jdbc:mysql://localhost:3306/db_itdoc?useSSL=false";
15+
public static String username = "root";
16+
public static String password = "12345678";
1717

1818
public static DataSource getDataSource() {
1919
Properties properties = new Properties();

‎src/main/java/com/vison/webmvc/controller/UserController.java

+25-10
Original file line numberDiff line numberDiff line change
@@ -5,11 +5,16 @@
55
import com.vison.webmvc.Response;
66
import com.vison.webmvc.config.Log;
77
import com.vison.webmvc.dao.UserMapper;
8+
import com.vison.webmvc.framework.HibernateLoader;
89
import com.vison.webmvc.framework.MybatisLoader;
910
import com.vison.webmvc.framework.PostMapping;
11+
import javax.persistence.EntityManager;
12+
import javax.persistence.EntityManagerFactory;
1013
import javax.servlet.http.HttpServletRequest;
1114
import javax.servlet.http.HttpServletResponse;
1215
import org.apache.ibatis.session.SqlSession;
16+
import org.hibernate.Session;
17+
import org.hibernate.Transaction;
1318
//import org.hibernate.Session;
1419
//import org.hibernate.Transaction;
1520

@@ -40,15 +45,25 @@ public Response user(HttpServletRequest request, int id) {
4045
@PostMapping(path = "/user/add")
4146
public Response add(User user) {
4247
Log.info("request user", user);
43-
try {
44-
SqlSession session = MybatisLoader.getSqlSessionFactory().openSession();
45-
UserMapper mapper = session.getMapper(UserMapper.class);
46-
int id = mapper.insertUser(user);
47-
session.commit();
48-
Log.debug("返回", id);
49-
} catch (Exception e) {
50-
Log.error("保存失败", e);
51-
}
52-
return new Response(0, "保存", user);
48+
Transaction transaction = null;
49+
Session session = HibernateLoader.getSessionFactory().openSession(); // start a transaction
50+
transaction = session.beginTransaction();
51+
// save the student object
52+
session.save(user);
53+
// commit transaction
54+
transaction.commit();
55+
session.close();
56+
return new Response(0, "保存");
57+
}
58+
59+
@GetMapping(path = "/user/delete")
60+
public Response delete(int id) {
61+
Log.info("id", id);
62+
EntityManagerFactory emf = HibernateLoader.emf;
63+
EntityManager entityManager = emf.createEntityManager();
64+
User user = entityManager.find(User.class, id);
65+
Log.info("user", user);
66+
entityManager.remove(user);
67+
return new Response(0, "删除成功");
5368
}
5469
}

‎src/main/java/com/vison/webmvc/entity/User.java

+58-3
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,64 @@
11
package com.vison.webmvc.entity;
22

3+
import javax.persistence.Column;
4+
import javax.persistence.Entity;
5+
import javax.persistence.GeneratedValue;
6+
import javax.persistence.GenerationType;
7+
import javax.persistence.Id;
8+
import javax.persistence.Table;
9+
310
/**
411
*
512
* @author vison.cao <visonforcoding@gmail.com>
613
*/
14+
import javax.persistence.Column;
15+
import javax.persistence.Entity;
16+
import javax.persistence.GeneratedValue;
17+
import javax.persistence.GenerationType;
18+
import javax.persistence.Id;
19+
import javax.persistence.Table;
20+
21+
/**
22+
* User.java This is a model class represents a User entity
23+
*
24+
* @author Ramesh Fadatare
25+
*
26+
*/
27+
@Entity
28+
@Table(name = "instructor")
729
public class User {
830

9-
private int id;
31+
@Id
32+
@GeneratedValue(strategy = GenerationType.IDENTITY)
33+
@Column(name = "id")
34+
protected int id;
1035

11-
private String name;
36+
@Column(name = "name")
37+
protected String name;
1238

13-
private String email;
39+
@Column(name = "email")
40+
protected String email;
41+
42+
@Column(name = "country")
43+
protected String country;
44+
45+
public User() {
46+
}
47+
48+
public User(String name, String email, String country) {
49+
super();
50+
this.name = name;
51+
this.email = email;
52+
this.country = country;
53+
}
54+
55+
public User(int id, String name, String email, String country) {
56+
super();
57+
this.id = id;
58+
this.name = name;
59+
this.email = email;
60+
this.country = country;
61+
}
1462

1563
public int getId() {
1664
return id;
@@ -36,4 +84,11 @@ public void setEmail(String email) {
3684
this.email = email;
3785
}
3886

87+
public String getCountry() {
88+
return country;
89+
}
90+
91+
public void setCountry(String country) {
92+
this.country = country;
93+
}
3994
}

‎src/main/java/com/vison/webmvc/framework/ContextServletListener.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -22,13 +22,16 @@ public class ContextServletListener implements ServletContextListener {
2222
@Override
2323
public void contextInitialized(ServletContextEvent sce) {
2424
Log.info("应用程序启动...");
25+
ViewEngine.load(sce.getServletContext());
2526
String packageName = "com.vison.webmvc.controller";
2627
ConfigurationBuilder config = new ConfigurationBuilder();
2728
config.filterInputsBy(new FilterBuilder().includePackage(packageName));
2829
config.addUrls(ClasspathHelper.forPackage(packageName));
2930
config.setScanners(new MethodAnnotationsScanner());
3031
App.f = new Reflections(config);
31-
MybatisLoader.getSqlSessionFactory();
32+
// MybatisLoader.getSqlSessionFactory();
33+
// HibernateLoader.initEmf("itdoc");
34+
HibernateLoader.getSessionFactory();
3235
}
3336

3437
@Override

‎src/main/java/com/vison/webmvc/framework/DispatchServlet.java

+27-40
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
import java.lang.reflect.InvocationTargetException;
1111
import java.lang.reflect.Method;
1212
import java.lang.reflect.Parameter;
13+
import java.util.ArrayList;
1314
import java.util.Set;
1415
import java.util.logging.Level;
1516
import java.util.logging.Logger;
@@ -31,16 +32,16 @@
3132
*/
3233
@WebServlet(name = "DispatchServlet", urlPatterns = {"/"})
3334
public class DispatchServlet extends HttpServlet {
34-
35+
3536
private Reflections f;
36-
37+
3738
@Override
3839
public void init() throws ServletException {
39-
ViewEngine.load(this.getServletContext());
40+
// ViewEngine.load(this.getServletContext());
4041
f = App.f;
41-
42+
4243
}
43-
44+
4445
@Override
4546
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
4647
throws ServletException, IOException {
@@ -50,7 +51,7 @@ protected void doGet(HttpServletRequest req, HttpServletResponse resp)
5051
Logger.getLogger(DispatchServlet.class.getName()).log(Level.SEVERE, null, ex);
5152
}
5253
}
53-
54+
5455
@Override
5556
protected void doPost(HttpServletRequest req, HttpServletResponse resp)
5657
throws ServletException, IOException {
@@ -59,9 +60,9 @@ protected void doPost(HttpServletRequest req, HttpServletResponse resp)
5960
} catch (NullRouteException ex) {
6061
Logger.getLogger(DispatchServlet.class.getName()).log(Level.SEVERE, null, ex);
6162
}
62-
63+
6364
}
64-
65+
6566
private void process(HttpServletRequest req, HttpServletResponse resp, RequestMethod requestMethod)
6667
throws NullRouteException, IOException {
6768
resp.setContentType("text/html");
@@ -70,14 +71,20 @@ private void process(HttpServletRequest req, HttpServletResponse resp, RequestMe
7071
Object res = null;
7172
try {
7273
Method invokeMethod = this.getMaps(path, requestMethod);
74+
Object[] arguments = new Object[0];
7375
switch (requestMethod) {
7476
case GET:
75-
res = getDispatch(req, resp, invokeMethod);
77+
arguments = getDispatch(req, resp, invokeMethod);
7678
break;
7779
case POST:
78-
res = postDispatch(req, resp, invokeMethod);
80+
arguments = postDispatch(req, resp, invokeMethod);
7981
break;
8082
}
83+
Object obj;
84+
obj = invokeMethod.getDeclaringClass().getDeclaredConstructor().newInstance();
85+
res = invokeMethod.invoke(obj, arguments);
86+
} catch (InvocationTargetException e) {
87+
Log.error("发生错误", e.getCause());
8188
} catch (NullRouteException ex) {
8289
res = "404 Not Found";
8390
} catch (Exception e) {
@@ -87,10 +94,8 @@ private void process(HttpServletRequest req, HttpServletResponse resp, RequestMe
8794
resp.getWriter().write(responseBody);
8895
resp.getWriter().flush();
8996
}
90-
91-
private Object getDispatch(HttpServletRequest request, HttpServletResponse response, Method invokeMethod) {
92-
93-
Object res = null;
97+
98+
private Object[] getDispatch(HttpServletRequest request, HttpServletResponse response, Method invokeMethod) {
9499
Parameter[] parameters = invokeMethod.getParameters();
95100
Object[] arguments = new Object[parameters.length];
96101
for (int i = 0; i < parameters.length; i++) {
@@ -116,21 +121,11 @@ private Object getDispatch(HttpServletRequest request, HttpServletResponse respo
116121
throw new RuntimeException("Missing handler for type: " + parameterClass);
117122
}
118123
}
119-
Object obj;
120-
try {
121-
obj = invokeMethod.getDeclaringClass().getDeclaredConstructor().newInstance();
122-
res = invokeMethod.invoke(obj, arguments);
123-
} catch (Exception e) {
124-
InvocationTargetException targetEx = (InvocationTargetException) e;
125-
Throwable trowEx = targetEx.getTargetException();
126-
Log.error("方法invoke失败", trowEx);
127-
}
128-
return res;
124+
return arguments;
129125
}
130-
131-
private Object postDispatch(HttpServletRequest request, HttpServletResponse response, Method invokeMethod)
126+
127+
private Object[] postDispatch(HttpServletRequest request, HttpServletResponse response, Method invokeMethod)
132128
throws IOException {
133-
Object res = null;
134129
Parameter[] parameters = invokeMethod.getParameters();
135130
Object[] arguments = new Object[parameters.length];
136131
for (int i = 0; i < parameters.length; i++) {
@@ -151,17 +146,9 @@ private Object postDispatch(HttpServletRequest request, HttpServletResponse resp
151146
arguments[i] = gson.fromJson(reader, parameterClass);
152147
}
153148
}
154-
Object obj;
155-
try {
156-
obj = invokeMethod.getDeclaringClass().getDeclaredConstructor().newInstance();
157-
res = invokeMethod.invoke(obj, arguments);
158-
} catch (Exception e) {
159-
Log.error("方法invoke失败", e);
160-
}
161-
return res;
162-
149+
return arguments;
163150
}
164-
151+
165152
private String getOrDefault(HttpServletRequest request, String name, String defaultValue) {
166153
String s = request.getParameter(name);
167154
return s == null ? defaultValue : s;
@@ -181,9 +168,9 @@ private String handInvokeRes(Object obj) {
181168
String jsonRes = gson.toJson(obj);
182169
return jsonRes;
183170
}
184-
171+
185172
private Method getMaps(String path, RequestMethod requestMethod) throws NullRouteException {
186-
173+
187174
if (requestMethod == RequestMethod.GET) {
188175
Set<Method> resources = f.getMethodsAnnotatedWith(GetMapping.class);
189176
for (Method method : resources) {
@@ -202,7 +189,7 @@ private Method getMaps(String path, RequestMethod requestMethod) throws NullRout
202189
}
203190
}
204191
}
205-
192+
206193
throw new NullRouteException();
207194
}
208195
}

‎src/main/java/com/vison/webmvc/framework/HibernateLoader.java

+54
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,54 @@
1+
package com.vison.webmvc.framework;
2+
3+
import com.vison.webmvc.config.DatabaseConfig;
4+
import com.vison.webmvc.config.Log;
5+
import com.vison.webmvc.entity.User;
6+
import java.io.File;
7+
import javax.persistence.EntityManagerFactory;
8+
import javax.persistence.Persistence;
9+
import org.hibernate.SessionFactory;
10+
import org.hibernate.boot.model.relational.Database;
11+
import org.hibernate.boot.registry.StandardServiceRegistryBuilder;
12+
import org.hibernate.cache.spi.access.AccessType;
13+
import org.hibernate.cfg.Configuration;
14+
import org.hibernate.cfg.Environment;
15+
import org.hibernate.service.ServiceRegistry;
16+
17+
/**
18+
*
19+
* @author vison.cao <visonforcoding@gmail.com>
20+
*/
21+
public class HibernateLoader {
22+
23+
public static EntityManagerFactory emf;
24+
public static SessionFactory sessionFactory = null;
25+
26+
public static void initEmf(String unitName) {
27+
Log.info("init emf...");
28+
emf = Persistence.createEntityManagerFactory(unitName);
29+
}
30+
31+
public static SessionFactory getSessionFactory() {
32+
if (sessionFactory == null) {
33+
try {
34+
Configuration cfg = new Configuration();
35+
cfg.setProperty(Environment.DRIVER, "com.mysql.cj.jdbc.Driver");
36+
cfg.setProperty(Environment.URL, DatabaseConfig.url);
37+
cfg.setProperty(Environment.USER, DatabaseConfig.username);
38+
cfg.setProperty(Environment.PASS, DatabaseConfig.password);
39+
cfg.setProperty(Environment.DIALECT, "org.hibernate.dialect.MySQL5Dialect");
40+
cfg.setProperty(Environment.SHOW_SQL, "true");
41+
cfg.setProperty(Environment.HBM2DDL_AUTO, "update");
42+
cfg.setProperty(Environment.STORAGE_ENGINE, "InnoDB");
43+
cfg.addAnnotatedClass(User.class);
44+
ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder()
45+
.applySettings(cfg.getProperties()).build();
46+
sessionFactory = cfg.buildSessionFactory(serviceRegistry);
47+
} catch (Throwable ex) {
48+
Log.error("配置hibernate 失败", ex);
49+
// throw new ExceptionInInitializerError(ex);
50+
}
51+
}
52+
return sessionFactory;
53+
}
54+
}

‎src/main/resources/META-INF/persistence.xml

+16
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<persistence version="2.1" xmlns="http://xmlns.jcp.org/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd">
3+
<persistence-unit name="itdoc" transaction-type="RESOURCE_LOCAL">
4+
<provider>org.hibernate.jpa.HibernatePersistenceProvider</provider>
5+
<class>com.vison.webmvc.entity.User</class>
6+
<properties>
7+
<property name="javax.persistence.jdbc.url" value="jdbc:mysql://localhost:3306/db_itdoc?useSSl=false"/>
8+
<property name="javax.persistence.jdbc.user" value="root"/>
9+
<property name="javax.persistence.jdbc.driver" value="com.mysql.cj.jdbc.Driver"/>
10+
<property name="javax.persistence.jdbc.password" value="12345678"/>
11+
<!--<property name="javax.persistence.schema-generation.database.action" value="drop-and-create"/>-->
12+
<property name="hibernate.show_sql" value="true"/>
13+
<property name="hibernate.format_sql" value="true"/>
14+
</properties>
15+
</persistence-unit>
16+
</persistence>

‎src/main/resources/log4j2.xml

+1-1
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
</Appenders>
1212

1313
<Loggers>
14-
<Root level="DEBUG">
14+
<Root level="INFO">
1515
<AppenderRef ref="Console" />
1616
</Root>
1717
</Loggers>

0 commit comments

Comments
 (0)
Please sign in to comment.