package com.gaoming.querydsl.dao.entity;
import javax.annotation.Generated;
import java.io.Serializable;
/**
 * SysRoleDo is a Querydsl bean type
 */
@Generated("com.querydsl.codegen.BeanSerializer")
public class SysRoleDo implements Serializable {
    private Integer eee;
    private Integer etxt;
    private Integer roleId;
    private String roleName;
    public Integer getEee() {
        return eee;
    }
    public void setEee(Integer eee) {
        this.eee = eee;
    }
    public Integer getEtxt() {
        return etxt;
    }
    public void setEtxt(Integer etxt) {
        this.etxt = etxt;
    }
    public Integer getRoleId() {
        return roleId;
    }
    public void setRoleId(Integer roleId) {
        this.roleId = roleId;
    }
    public String getRoleName() {
        return roleName;
    }
    public void setRoleName(String roleName) {
        this.roleName = roleName;
    }
    @Override
    public String toString() {
         return "eee = " + eee + ", etxt = " + etxt + ", roleId = " + roleId + ", roleName = " + roleName;
    }
}

package com.gaoming.querydsl.dao.query;
import static com.querydsl.core.types.PathMetadataFactory.*;
import com.gaoming.querydsl.dao.entity.SysRoleDo;
import com.querydsl.core.types.dsl.*;
import com.querydsl.core.types.PathMetadata;
import javax.annotation.Generated;
import com.querydsl.core.types.Path;
import com.querydsl.sql.ColumnMetadata;
import java.sql.Types;
/**
 * QSysRole is a Querydsl query type for SysRoleDo
 */
@Generated("com.querydsl.sql.codegen.MetaDataSerializer")
public class QSysRole extends com.querydsl.sql.RelationalPathBase<SysRoleDo> {
    private static final long serialVersionUID = -1544683865;
    public static final QSysRole sysRole = new QSysRole("sys_role");
    public final NumberPath<Integer> eee = createNumber("eee", Integer.class);
    public final NumberPath<Integer> etxt = createNumber("etxt", Integer.class);
    public final NumberPath<Integer> roleId = createNumber("roleId", Integer.class);
    public final StringPath roleName = createString("roleName");
    public final com.querydsl.sql.PrimaryKey<SysRoleDo> primary = createPrimaryKey(roleId);
    public QSysRole(String variable) {
        super(SysRoleDo.class, forVariable(variable), "null", "sys_role");
        addMetadata();
    }
    public QSysRole(String variable, String schema, String table) {
        super(SysRoleDo.class, forVariable(variable), schema, table);
        addMetadata();
    }
    public QSysRole(String variable, String schema) {
        super(SysRoleDo.class, forVariable(variable), schema, "sys_role");
        addMetadata();
    }
    public QSysRole(Path<? extends SysRoleDo> path) {
        super(path.getType(), path.getMetadata(), "null", "sys_role");
        addMetadata();
    }
    public QSysRole(PathMetadata metadata) {
        super(SysRoleDo.class, metadata, "null", "sys_role");
        addMetadata();
    }
    public void addMetadata() {
        addMetadata(eee, ColumnMetadata.named("eee").withIndex(4).ofType(Types.INTEGER).withSize(10).notNull());
        addMetadata(etxt, ColumnMetadata.named("etxt").withIndex(3).ofType(Types.INTEGER).withSize(10).notNull());
        addMetadata(roleId, ColumnMetadata.named("role_id").withIndex(1).ofType(Types.INTEGER).withSize(10).notNull());
        addMetadata(roleName, ColumnMetadata.named("role_name").withIndex(2).ofType(Types.VARCHAR).withSize(50).notNull());
    }
}

package com.gaoming.querydsl.config;
import com.querydsl.sql.MySQLTemplates;
import com.querydsl.sql.SQLQueryFactory;
import com.querydsl.sql.SQLTemplates;
import com.querydsl.sql.spring.SpringConnectionProvider;
import com.querydsl.sql.spring.SpringExceptionTranslator;
import com.zaxxer.hikari.HikariDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import javax.inject.Provider;
import javax.sql.DataSource;
import java.sql.Connection;
/**
 * @file: QueryDslConfig
 * @author: gaoming
 * @date: 2021/04/25
 * @version: 1.0
 * @description:
 **/
@Configuration
public class QueryDslConfig {
    @Bean
    public DataSource dataSource() {
        // implementation omitted
        // 这里使用HikariCP链接池
        HikariDataSource hikariDataSource = new HikariDataSource();
        hikariDataSource.setJdbcUrl("jdbc:mysql://localhost:3306/boke?useUnicode=true&characterEncoding=UTF-8");
        hikariDataSource.setUsername("root");
        hikariDataSource.setPassword("root");
        return hikariDataSource;
    }
    
    // 配置事务
    @Bean
    public DataSourceTransactionManager transactionManager() {
        return new DataSourceTransactionManager(dataSource());
    }
    
    // 使用Mysql模板
    @Bean
    public com.querydsl.sql.Configuration querydslConfiguration() {
        SQLTemplates templates = MySQLTemplates.builder().quote().build();
        com.querydsl.sql.Configuration configuration = new com.querydsl.sql.Configuration(templates);
        configuration.setExceptionTranslator(new SpringExceptionTranslator());
        return configuration;
    }
    
    // 向Spring容器注入 sqlQueryFactory
    @Bean(name = "sqlQueryFactory")
    public SQLQueryFactory queryFactory() {
        Provider<Connection> provider = new SpringConnectionProvider(dataSource());
        return new SQLQueryFactory(querydslConfiguration(), provider);
    }
}

package com.gaoming.querydsl.controller;
import com.gaoming.querydsl.service.IndexService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
/**
 * @file: IndexController
 * @author: gaoming
 * @date: 2021/04/26
 * @version: 1.0
 * @description:
 **/
@RestController
@RequestMapping(value = "/index")
public class IndexController {
    @Autowired
    private IndexService indexService;
    @RequestMapping(value = "", method = RequestMethod.GET)
    public String index() {
        return indexService.query();
    }
}

@Service
public class IndexService {
    @Resource(name = "sqlQueryFactory")
    private SQLQueryFactory sqlQueryFactory;
    @Transactional
    public String query() {
        List<SysRoleDo> fetch = sqlQueryFactory.selectFrom(sysRole).fetch();
        return fetch.stream().map(SysRoleDo::getRoleName).collect(Collectors.joining(","));
    }
}