MyBatis-Plus+Druid配置及应用详解

  <dependency>
  <groupid>com.baomidou</groupid>
   <artifactid>mybatis-plus-boot-starter</artifactid>
   <version>3.0.6</version>
 </dependency>
 <dependency>
  <groupid>org.apache.velocity</groupid>
  <artifactid>velocity-engine-core</artifactid>
  <version>2.2</version>
 </dependency>

#mysql 连接配置
spring.datasource.url=jdbc:mysql://localhost:3306/mybatis?usessl=false&servertimezone=utc
spring.datasource.username=root
spring.datasource.password=password
spring.datasource.driver-class-name=com.mysql.jdbc.driver
spring.datasource.type=com.alibaba.druid.pool.druiddatasource

@springbootapplication
@enabletransactionmanagement
@enableeurekaclient
@mapperscan("com.example.demo.dao")
public class demoapplication {

 public static void main(string[] args) {
 springapplication.run(demoapplication.class, args);
 }
}

@data
@tablename("area")
@tostring(callsuper=true, includefieldnames=true)
@allargsconstructor
@noargsconstructor
public class area implements serializable{
 
 private static final long serialversionuid = 1l;
 private string id;
 private string name;
 private int sort; 
}

public interface areamapper extends basemapper<area> {
 
 //通过mybatis-plus提供的注解,直接自定义sql
 @select("select name from area where sort > ${sort}")
 list<string> getbysort2(@param("sort")int sort);
}

public interface iareaservice {
 
 public area getbyid(string id);
 
 public list<area> selectall();
 
 public int updatebyprimarykeyselective(area record);
 
 public int deletebyprimarykey(string id);
 
 public int insertselective(area record);
 
 public list<area> getbysort();
 
 public list<string> getbysort2(int sort);

}

@service
public class areaserviceimpl implements iareaservice {

 @autowired
 public areamapper areamapper;

 //使用mybatis-plus自带crud方法
 @override
 public area getbyid(string id) {
 return areamapper.selectbyid(id);
 } 
 
 @override
 public list<area> selectall() {
 return areamapper.selectlist(null);
 }
 
 @override
 @transactional
 public int updatebyprimarykeyselective(area record) {
 return areamapper.updatebyid(record);
 }
 
 @override
 public int deletebyprimarykey(string id) {
 return areamapper.deletebyid(id);
 }
 
 @override
 public int insertselective(area record) {
 return areamapper.insert(record);
 }
 
 //使用mybatis-plus提供的条件构造器,拼接条件
 @override
 public list<area> getbysort(){
 querywrapper<area> querywrapper = new querywrapper<>();
 querywrapper.lambda().gt(area::getsort, 40)
  .lt(area::getsort, 80);
 return areamapper.selectlist(querywrapper);
 }
 
 //通过mybatis-plus提供的注解,直接自定义sql(定义在mapper中)
 @override
 public list<string> getbysort2(int sort){
 return areamapper.getbysort2(sort);
 
 }

}

@restcontroller
@requestmapping("/area")
public class areacontroller {

 @autowired
 private iareaservice areaservice;
 
 @autowired
 private dbpropertiesservice dbproservice;
 
 @autowired
 private area area;
 
 @resource
 protected httpservletrequest request;

 @requestmapping(value = "/getareainfo",method=requestmethod.get)
 public area getareainfo(@requestparam(value="id") string id) {
 area = areaservice.getbyid(id);
 return area;
 }
 
 @requestmapping(value = "/getareaallinfo",method=requestmethod.get)
 public list<area> getareainfo() {
 list<area> arlist = areaservice.selectall();
 return arlist;
 }
 
 @requestmapping(value ="/updateareaname",method=requestmethod.put)
 public int updateareainfo(@requestparam(value="id") string id,@requestparam(value="name",required=false) string name,@requestparam(value="sort",required=false) integer sort) {
 area.setid(id);
 area.setname(name); 
 area.setsort(sort);
 int ar = areaservice.updatebyprimarykeyselective(area);
 return ar;
 }
 
 @requestmapping(value ="/deleteareaname",method=requestmethod.delete)
 public int deleteareainfo(@requestparam(value="id") string id) {
 int ar = areaservice.deletebyprimarykey(id);
 return ar;
 }
 
// @requestmapping(value ="/insertareaname",method=requestmethod.post)
// public int insertareainfo(@requestparam(value="id") string id,@requestparam(value="name",required=false) string name,@requestparam(value="sort",required=false) integer sort) {
// area.setid(id);
// area.setname(name); 
// area.setsort(sort);
// int ar = areaservice.insertselective(area);
// return ar;
// } 
 
 @requestmapping(value ="/insertareaname",method=requestmethod.post)
 public int insertareainfo(@requestbody area area) {
 int ar = areaservice.insertselective(area);
 return ar;
 }
 
 @requestmapping(value ="/selectbysort",method=requestmethod.get)
 public list<area> selectareasort() {
 list<area> arlist = areaservice.getbysort();
 return arlist;
 }
 
 @requestmapping(value ="/selectbysort2",method=requestmethod.get)
 public list<string> selectareasort2(@requestparam(value="sort") int sort) {
 list<string> arlist = areaservice.getbysort2(sort);
 return arlist;
 }
}

 <dependency>
   <groupid>com.alibaba</groupid>
   <artifactid>druid</artifactid>
   <version>1.1.3</version>
  </dependency>

spring.datasource.type需要指定为druid
spring.datasource.url=jdbc:mysql://localhost:3306/mybatis?usessl=false&servertimezone=utc
spring.datasource.username=root
spring.datasource.password=password
spring.datasource.driver-class-name=com.mysql.jdbc.driver
spring.datasource.type=com.alibaba.druid.pool.druiddatasource

@configurationproperties(prefix = "spring.datasource")
public class druidconfiguration {
 
 private string url;
 private string username;
 private string password;
 private string driverclassname;
 private int initialsize = 5;
 private int minidle = 5;
 private int maxactive = 10;
 private int maxwait = 2;
 private int timebetweenevictionrunsmillis = 1000 * 60;
 private int minevictableidletimemillis = 1000 * 60 * 30;
 private string validationquery;
 private boolean testwhileidle = false;
 private boolean testonborrow = true;
 private boolean testonreturn = false;
 private boolean poolpreparedstatements = false;
 private int maxpoolpreparedstatementperconnectionsize = -1;
 private string filters;
 private boolean useglobaldatasourcestat = false;
 private string connectionproperties;

@configuration
@configurationproperties(prefix = "spring.datasource")
public class datasource2config {
 
 private string url;
 private string username;
 private string password;
 
 @bean
 public datasource getdatasource() {
 druiddatasource datasource = new druiddatasource();
 datasource.seturl(url);
 datasource.setusername(username);// 用户名
 datasource.setpassword(password);// 密码
 return datasource;
 }
 
 public string geturl() {
 return url;
 }
 
 public void seturl(string url) {
 this.url = url;
 }
 
 public string getusername() {
 return username;
 }
 
 public void setusername(string username) {
 this.username = username;
 }
 
 public string getpassword() {
 return password;
 }
 
 public void setpassword(string password) {
 this.password = password;
 }
}

package com.example.demo.dao.druid;

import java.sql.sqlexception;
import java.util.hashmap;
import java.util.map;

import javax.sql.datasource;

import org.springframework.beans.factory.annotation.qualifier;
import org.springframework.boot.context.properties.configurationproperties;
import org.springframework.boot.web.servlet.filterregistrationbean;
import org.springframework.boot.web.servlet.servletregistrationbean;
import org.springframework.context.annotation.bean;
import org.springframework.context.annotation.configuration;
import org.springframework.context.annotation.primary;
import org.springframework.jdbc.datasource.datasourcetransactionmanager;
import org.springframework.stereotype.component;
import org.springframework.transaction.platformtransactionmanager;

import com.alibaba.druid.pool.druiddatasource;
import com.alibaba.druid.support.http.statviewservlet;
import com.alibaba.druid.support.http.webstatfilter;


@configuration
public class druidconfiguration {
 
 @bean
 public servletregistrationbean druidservlet() {
  //logger.info("init druid servlet configuration ");
  servletregistrationbean servletregistrationbean = new servletregistrationbean();
  servletregistrationbean.setservlet(new statviewservlet());
  servletregistrationbean.addurlmappings("/druid/*");
  map<string, string> initparameters = new hashmap<string, string>();
  initparameters.put("loginusername", "admin");
  initparameters.put("loginpassword", "admin");
  initparameters.put("resetenable", "false");
  initparameters.put("allow", ""); 
  initparameters.put("deny", "");
  servletregistrationbean.setinitparameters(initparameters);
  return servletregistrationbean;
 }

 @bean
 public filterregistrationbean filterregistrationbean() {
  filterregistrationbean filterregistrationbean = new filterregistrationbean();
  filterregistrationbean.setfilter(new webstatfilter());
  filterregistrationbean.addurlpatterns("/*");
  filterregistrationbean.addinitparameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
  return filterregistrationbean;
 }
 
 @bean
 @primary
 public platformtransactionmanager transactionmanager(@qualifier("datasource") datasource datasource) {
  datasourcetransactionmanager datasourcetransactionmanager = new datasourcetransactionmanager();
  datasourcetransactionmanager.setdatasource(datasource);
  return datasourcetransactionmanager;
 }
 
 
}

//druid配置bean
@component
@configurationproperties(prefix = "spring.datasource")
class druiddatasourceproperties {
 
 private string url;
 private string username;
 private string password;
 private string driverclassname;
 private int initialsize = 5;
 private int minidle = 5;
 private int maxactive = 10;
 private int maxwait = 2;
 private int timebetweenevictionrunsmillis = 1000 * 60;
 private int minevictableidletimemillis = 1000 * 60 * 30;
 private string validationquery;
 private boolean testwhileidle = false;
 private boolean testonborrow = true;
 private boolean testonreturn = false;
 private boolean poolpreparedstatements = false;
 private int maxpoolpreparedstatementperconnectionsize = -1;
 private string filters = "stat";
 private boolean useglobaldatasourcestat = false;
 private string connectionproperties;
 
 @bean  //声明其为bean实例,将数据源设置为druid
 @primary //在同样的datasource中，首先使用被标注的datasource
 public datasource datasource() {
  druiddatasource datasource = new druiddatasource();
  datasource.seturl(url);
  datasource.setusername(username);
  datasource.setpassword(password);
  datasource.setdriverclassname(driverclassname);

  //configuration
  datasource.setinitialsize(initialsize);
  datasource.setminidle(minidle);
  datasource.setmaxactive(maxactive);
  datasource.setmaxwait(maxwait);
  datasource.settimebetweenevictionrunsmillis(timebetweenevictionrunsmillis);
  datasource.setminevictableidletimemillis(minevictableidletimemillis);
  datasource.setvalidationquery(validationquery);
  datasource.settestwhileidle(testwhileidle);
  datasource.settestonborrow(testonborrow);
  datasource.settestonreturn(testonreturn);
  datasource.setpoolpreparedstatements(poolpreparedstatements);
  datasource.setmaxpoolpreparedstatementperconnectionsize(maxpoolpreparedstatementperconnectionsize);
  try {
   datasource.setfilters(filters);
  } catch (sqlexception e) {
   system.err.println("druid configuration initialization filter: " + e);
  }
  datasource.setconnectionproperties(connectionproperties);
  return datasource;
 }
 
 public string geturl() {
  return url;
 }

 public void seturl(string url) {
  this.url = url;
 }

 public string getusername() {
  return username;
 }

 public void setusername(string username) {
  this.username = username;
 }

 public string getpassword() {
  return password;
 }

 public void setpassword(string password) {
  this.password = password;
 }

 public string getdriverclassname() {
  return driverclassname;
 }

 public void setdriverclassname(string driverclassname) {
  this.driverclassname = driverclassname;
 }

 public int getinitialsize() {
  return initialsize;
 }

 public void setinitialsize(int initialsize) {
  this.initialsize = initialsize;
 }

 public int getminidle() {
  return minidle;
 }

 public void setminidle(int minidle) {
  this.minidle = minidle;
 }

 public int getmaxactive() {
  return maxactive;
 }

 public void setmaxactive(int maxactive) {
  this.maxactive = maxactive;
 }

 public int getmaxwait() {
  return maxwait;
 }

 public void setmaxwait(int maxwait) {
  this.maxwait = maxwait;
 }

 public int gettimebetweenevictionrunsmillis() {
  return timebetweenevictionrunsmillis;
 }

 public void settimebetweenevictionrunsmillis(int timebetweenevictionrunsmillis) {
  this.timebetweenevictionrunsmillis = timebetweenevictionrunsmillis;
 }

 public int getminevictableidletimemillis() {
  return minevictableidletimemillis;
 }

 public void setminevictableidletimemillis(int minevictableidletimemillis) {
  this.minevictableidletimemillis = minevictableidletimemillis;
 }

 public string getvalidationquery() {
  return validationquery;
 }

 public void setvalidationquery(string validationquery) {
  this.validationquery = validationquery;
 }

 public boolean istestwhileidle() {
  return testwhileidle;
 }

 public void settestwhileidle(boolean testwhileidle) {
  this.testwhileidle = testwhileidle;
 }

 public boolean istestonborrow() {
  return testonborrow;
 }

 public void settestonborrow(boolean testonborrow) {
  this.testonborrow = testonborrow;
 }

 public boolean istestonreturn() {
  return testonreturn;
 }

 public void settestonreturn(boolean testonreturn) {
  this.testonreturn = testonreturn;
 }

 public boolean ispoolpreparedstatements() {
  return poolpreparedstatements;
 }

 public void setpoolpreparedstatements(boolean poolpreparedstatements) {
  this.poolpreparedstatements = poolpreparedstatements;
 }

 public int getmaxpoolpreparedstatementperconnectionsize() {
  return maxpoolpreparedstatementperconnectionsize;
 }

 public void setmaxpoolpreparedstatementperconnectionsize(int maxpoolpreparedstatementperconnectionsize) {
  this.maxpoolpreparedstatementperconnectionsize = maxpoolpreparedstatementperconnectionsize;
 }

 public string getfilters() {
  return filters;
 }

 public void setfilters(string filters) {
  this.filters = filters;
 }


 public boolean isuseglobaldatasourcestat() {
  return useglobaldatasourcestat;
 }

 public void setuseglobaldatasourcestat(boolean useglobaldatasourcestat) {
  this.useglobaldatasourcestat = useglobaldatasourcestat;
 }

 public string getconnectionproperties() {
  return connectionproperties;
 }

 public void setconnectionproperties(string connectionproperties) {
  this.connectionproperties = connectionproperties;
 }
}