You need to sign in or sign up before continuing.
提交 9de1b393 编写于 作者: Q qinyingjie

fix:FactoryBean使用

上级 c9afe548
CREATE TABLE `t_book`
(
`userId` VARCHAR(32) DEFAULT NULL COMMENT '用户id',
`username` VARCHAR(32) DEFAULT NULL COMMENT '名字',
`ustatus` VARCHAR(32) DEFAULT NULL COMMENT '状态'
) ENGINE = InnoDB
DEFAULT CHARSET = utf8;
\ No newline at end of file
......@@ -56,6 +56,22 @@
<artifactId>druid</artifactId>
<version>1.2.3</version>
</dependency>
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjrt</artifactId>
<version>1.9.7</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>5.3.8</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>5.3.8</version>
<scope>compile</scope>
</dependency>
</dependencies>
</project>
\ No newline at end of file
......@@ -10,6 +10,19 @@ import java.util.List;
* @date : 2022/11/12 19:22
*/
public class Book {
/**
* 用户id
*/
private String userId;
/**
* 用户名
*/
private String username;
/**
* 状态
*/
private String ustatus;
/**
* 名称
*/
......@@ -38,6 +51,42 @@ public class Book {
this.list = list;
}
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getUstatus() {
return ustatus;
}
public void setUstatus(String ustatus) {
this.ustatus = ustatus;
}
public String getBname() {
return bname;
}
public String getBauthor() {
return bauthor;
}
public List<String> getList() {
return list;
}
@Override
public String toString() {
return "Book{" +
......@@ -46,4 +95,12 @@ public class Book {
", list=" + list +
'}';
}
/**
* 购买方法
*/
public void buy() {
System.out.println("购买书籍.....");
}
}
package com.kwan.spring5;
import org.springframework.stereotype.Component;
/**
* 用户
*
......@@ -7,6 +9,7 @@ package com.kwan.spring5;
* @version : 2.2.0
* @date : 2022/11/12 19:22
*/
@Component(value = "user")
public class User {
/**
......@@ -16,6 +19,10 @@ public class User {
System.out.println("访问user成功");
}
public void add() {
System.out.println("访问user成功");
}
@Override
public String toString() {
return "User{}";
......
package com.kwan.spring5.dao;
import com.kwan.spring5.Book;
public interface BookDao {
void add(Book book);
}
......@@ -13,4 +13,17 @@ public interface UserDao {
* 更新
*/
void update();
/**
* 新增
* @param a
* @param b
* @return
*/
public int add(int a,int b);
/**
* 更新
*/
public String update(String id);
}
package com.kwan.spring5.dao.impl;
import com.kwan.spring5.Book;
import com.kwan.spring5.dao.BookDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
@Repository
public class BookDaoImpl implements BookDao {
/**
* 注入 JdbcTemplate
*/
@Autowired
private JdbcTemplate jdbcTemplate;
/**
* 添加的方法
*
* @param book
*/
@Override
public void add(Book book) {
//1 创建 sql 语句
String sql = "INSERT INTO t_book VALUES(?,?,?)";
//2 调用方法实现
Object[] args = {book.getUserId(), book.getUsername(), book.getUstatus()};
int update = jdbcTemplate.update(sql, args);
System.out.println(update);
}
}
\ No newline at end of file
......@@ -12,8 +12,19 @@ import org.springframework.stereotype.Repository;
*/
@Repository(value = "userDaoImpl")
public class UserDaoImpl implements UserDao {
@Override
public void update() {
System.out.println("dao update...........");
}
@Override
public int add(int a, int b) {
return a + b;
}
@Override
public String update(String id) {
return id;
}
}
package com.kwan.spring5.proxy;
public class BookProxy {
public void before() {
}
}
package com.kwan.spring5.proxy;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;
/**
* 在增强类上面添加注解 @Order(数字类型值),数字类型值越小优先级越高
*
* @author : qinyingjie
* @version : 2.2.0
* @date : 2022/11/15 17:40
*/
@Component
@Aspect
@Order(1)
public class PersonProxy {
/**
* 相同切入点抽取
*/
@Pointcut(value = "execution(* com.kwan.spring5.User.add(..))")
public void pointdemo() {
}
//前置通知
//@Before注解表示作为前置通知
@Before(value = "pointdemo()")//相同切入点抽取使用!
public void before() {
System.out.println("before.........");
}
//后置通知(返回通知)
@AfterReturning(value = "execution(* com.kwan.spring5.User.add(..))")
public void afterReturning() {
System.out.println("afterReturning.........");
}
//最终通知
@After(value = "execution(* com.kwan.spring5.User.add(..))")
public void after() {
System.out.println("after.........");
}
//异常通知
@AfterThrowing(value = "execution(* com.kwan.spring5.User.add(..))")
public void afterThrowing() {
System.out.println("afterThrowing.........");
}
//环绕通知
@Around(value = "execution(* com.kwan.spring5.User.add(..))")
public void around(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
System.out.println("环绕之前.........");
//被增强的方法执行
proceedingJoinPoint.proceed();
System.out.println("环绕之后.........");
}
}
\ No newline at end of file
package com.kwan.spring5.proxy;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.util.Arrays;
/**
* 创建代理对象代码
*
* @author : qinyingjie
* @version : 2.2.0
* @date : 2022/11/15 17:04
*/
public class UserDaoProxy implements InvocationHandler {
/**
* 把创建的是谁的代理对象,把谁传递过来
* 有参数构造传递
*/
private Object obj;
public UserDaoProxy(Object obj) {
this.obj = obj;
}
/**
* 增强的逻辑
*
* @param proxy
* @param method
* @param args
* @return
* @throws Throwable
*/
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
//方法之前
System.out.println("方法之前执行...." + method.getName() + " :传递的参数..." + Arrays.toString(args));
//被增强的方法执行
Object res = method.invoke(obj, args);
//方法之后
System.out.println("方法之后执行...." + obj);
return res;
}
}
\ No newline at end of file
package com.kwan.spring5.proxy;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;
@Component
@Aspect
@Order(2)
public class UserProxy {
/**
* 相同切入点抽取
*/
@Pointcut(value = "execution(* com.kwan.spring5.User.add(..))")
public void pointdemo() {
}
//前置通知
//@Before注解表示作为前置通知
@Before(value = "pointdemo()")//相同切入点抽取使用!
public void before() {
System.out.println("before.........");
}
//后置通知(返回通知)
@AfterReturning(value = "execution(* com.kwan.spring5.User.add(..))")
public void afterReturning() {
System.out.println("afterReturning.........");
}
//最终通知
@After(value = "execution(* com.kwan.spring5.User.add(..))")
public void after() {
System.out.println("after.........");
}
//异常通知
@AfterThrowing(value = "execution(* com.kwan.spring5.User.add(..))")
public void afterThrowing() {
System.out.println("afterThrowing.........");
}
//环绕通知
@Around(value = "execution(* com.kwan.spring5.User.add(..))")
public void around(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
System.out.println("环绕之前.........");
//被增强的方法执行
proceedingJoinPoint.proceed();
System.out.println("环绕之后.........");
}
}
\ No newline at end of file
package com.kwan.spring5.service;
import com.kwan.spring5.Book;
import com.kwan.spring5.dao.BookDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class BookService {
/**
* 注入 dao
*/
@Autowired
private BookDao bookDao;
/**
* 添加书籍
*
* @param book
*/
public void add(Book book) {
bookDao.add(book);
}
}
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
<!-- 开启注解扫描 -->
<context:component-scan base-package="com.kwan"></context:component-scan>
<!-- 开启Aspect生成代理对象-->
<aop:aspectj-autoproxy></aop:aspectj-autoproxy>
</beans>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
<!-- 开启注解扫描 -->
<context:component-scan base-package="com.kwan"></context:component-scan>
<!-- 开启Aspect生成代理对象-->
<aop:aspectj-autoproxy></aop:aspectj-autoproxy>
<!--1、创建两个类,增强类和被增强类,创建方法(同上一样)-->
<!--2、在 spring 配置文件中创建两个类对象-->
<!--创建对象-->
<bean id="book" class="com.kwan.spring5.Book"></bean>
<bean id="bookProxy" class="com.kwan.spring5.proxy.BookProxy"></bean>
<!--3、在 spring 配置文件中配置切入点-->
<!--配置 aop 增强-->
<aop:config>
<!--切入点-->
<aop:pointcut id="p" expression="execution(* com.kwan.spring5.Book.buy(..))"/>
<!--配置切面-->
<aop:aspect ref="bookProxy">
<!--增强作用在具体的方法上-->
<aop:before method="before" pointcut-ref="p"/>
</aop:aspect>
</aop:config>
</beans>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans
https://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
https://www.springframework.org/schema/context/spring-context.xsd">
<!-- 组件扫描 -->
<context:component-scan base-package="com.kwan"></context:component-scan>
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
destroy-method="close">
<property name="url" value="jdbc:mysql://localhost:3306/test"/>
<property name="username" value="root"/>
<property name="password" value="716288qwe"/>
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
</bean>
<!-- JdbcTemplate 对象 -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<!--注入 dataSource-->
<property name="dataSource" ref="dataSource"></property><!--set方式注入-->
</bean>
</beans>
\ No newline at end of file
import com.kwan.spring5.dao.UserDao;
import com.kwan.spring5.dao.impl.UserDaoImpl;
import com.kwan.spring5.proxy.UserDaoProxy;
import org.junit.Test;
import java.lang.reflect.Proxy;
/**
* jdk动态代理
*
* @author : qinyingjie
* @version : 2.2.0
* @date : 2022/11/12 18:43
*/
public class Spring_22_JDKProxy {
@Test
public void test1() {
//创建接口实现类代理对象
Class[] interfaces = {UserDao.class};
UserDaoImpl userDao = new UserDaoImpl();
/** 第一参数,类加载器
第二参数,增强方法所在的类,这个类实现的接口,(支持多个接口)
第三参数,实现这个接口 InvocationHandler,创建代理对象,写增强的部分 */
UserDao dao = (UserDao) Proxy.newProxyInstance(Spring_22_JDKProxy.class.getClassLoader(), interfaces,
new UserDaoProxy(userDao));
int result = dao.add(1, 2);
System.out.println("result:" + result);
}
}
import com.kwan.spring5.User;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* jdk动态代理
*
* @author : qinyingjie
* @version : 2.2.0
* @date : 2022/11/12 18:43
*/
public class Spring_23_ {
@Test
public void test1() {
ApplicationContext ctx =
new ClassPathXmlApplicationContext("spring23.xml");
User user = ctx.getBean("user",User.class);
user.add();
System.out.println(user);
}
}
import com.kwan.spring5.User;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* jdk动态代理
*
* @author : qinyingjie
* @version : 2.2.0
* @date : 2022/11/12 18:43
*/
public class Spring_24_ {
@Test
public void test1() {
ApplicationContext ctx =
new ClassPathXmlApplicationContext("spring23.xml");
User user = (User) ctx.getBean("user");
user.add();
System.out.println(user);
}
}
import com.kwan.spring5.Book;
import com.kwan.spring5.service.BookService;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* jdbc添加数据
*
* @author : qinyingjie
* @version : 2.2.0
* @date : 2022/11/12 18:43
*/
public class Spring_25_add {
@Test
public void test1() {
ApplicationContext ctx = new ClassPathXmlApplicationContext("spring25.xml");
BookService bookService = ctx.getBean("bookService", BookService.class);
Book book = new Book();
book.setUserId("1");
book.setUsername("1");
book.setUstatus("1");
bookService.add(book);
}
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册