【Java Web開發學習】Spring JPA
阿新 • • 發佈:2018-12-07
【Java Web開發學習】Spring JPA
轉載:https://www.cnblogs.com/yangchongxing/p/10082864.html
1、使用容器管理型別的JPA
JNDI資料來源
package cn.ycx.config; import javax.naming.NamingException; import javax.sql.DataSource; import org.springframework.context.annotation.Bean; import org.springframework.jndi.JndiObjectFactoryBean;public class DataSourceConfig { @Bean public DataSource dataSource() throws IllegalArgumentException, NamingException { System.out.println("dataSource..."); JndiObjectFactoryBean jndi = new JndiObjectFactoryBean(); jndi.setJndiName("jdbc/mysql"); jndi.setResourceRef(true);//自動新增 java:comp/env/ 字首 jndi.setProxyInterface(javax.sql.DataSource.class); jndi.afterPropertiesSet(); return (DataSource) jndi.getObject(); } }
宣告LocalContainerEntityManagerFactoryBean
package cn.ycx.config; import javax.sql.DataSource; import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.ComponentScan.Filter; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.FilterType; import org.springframework.context.annotation.Import; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.orm.jpa.JpaVendorAdapter; import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean; import org.springframework.orm.jpa.vendor.Database; import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter; import org.springframework.web.multipart.MultipartResolver; import org.springframework.web.multipart.support.StandardServletMultipartResolver; @Configuration @ComponentScan(basePackages = {"cn.ycx"}, excludeFilters = { @Filter( type=FilterType.ANNOTATION, value=org.springframework.stereotype.Controller.class) }) @Import(DataSourceConfig.class) public class RootConfig { @Bean public MultipartResolver multipartResolver() { System.out.println("multipartResolver..."); return new StandardServletMultipartResolver(); } @Bean public JdbcTemplate jdbcTemplate(DataSource dataSource) { System.out.println("jdbcTemplate..."); return new JdbcTemplate(dataSource); } @Bean public JpaVendorAdapter jpaVendorAdapter() { System.out.println("jpaVendorAdapter..."); HibernateJpaVendorAdapter adapter = new HibernateJpaVendorAdapter(); adapter.setDatabase(Database.MYSQL); adapter.setShowSql(true); adapter.setGenerateDdl(false); adapter.setDatabasePlatform("org.hibernate.dialect.MySQL55Dialect"); return adapter; } @Bean public LocalContainerEntityManagerFactoryBean entityManagerFactoryBean(DataSource dataSource, JpaVendorAdapter jpaVendorAdapter ) { System.out.println("localContainerEntityManagerFactoryBean..."); LocalContainerEntityManagerFactoryBean emfb = new LocalContainerEntityManagerFactoryBean(); emfb.setDataSource(dataSource); emfb.setJpaVendorAdapter(jpaVendorAdapter); emfb.setPackagesToScan("cn.ycx.entity"); return emfb; } }
編寫Repository
package cn.ycx.dao; import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashMap; import java.util.Map; import javax.persistence.EntityManager; import javax.persistence.EntityManagerFactory; import javax.persistence.EntityTransaction; import javax.persistence.PersistenceUnit; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcOperations; import org.springframework.stereotype.Repository; import org.springframework.transaction.annotation.Transactional; import cn.ycx.entity.User; @Repository public class IndexDao { @Autowired private JdbcOperations jdbcOperations; @PersistenceUnit private EntityManagerFactory emf; public void addUser() { SimpleDateFormat format = new SimpleDateFormat("yyyyMMddHHmmssSSS"); User user = new User(); user.setId(format.format(new Date())); user.setUsername("name"); EntityManager em = emf.createEntityManager(); EntityTransaction et = em.getTransaction(); et.begin();//開始事務 em.persist(user); et.commit();//提交事務 } public Object insert() { int count = jdbcOperations.update("insert into user(id,username,password)values(?,?,?)","2","user","user"); Map<String, String> data = new HashMap<String, String>(); data.put("count", String.valueOf(count)); return data; } public Object update() { int count = jdbcOperations.update("update user set username=?, password=? where id=?","admin","admin","1"); Map<String, String> data = new HashMap<String, String>(); data.put("count", String.valueOf(count)); return data; } }