小编Kep*_*ler的帖子

使用 Springdata mongo Query 删除集合中的所有文档

我想实现一个删除集合中所有文档的删除方法。我在 Spring Data 中使用 mongo db。这可以在 Mongo shell 中使用 db.myCollection.remove({}) 来完成。但是我想在我的数据访问层中编写一个方法来做到这一点。我没有在我的 Dao 类中使用 MongodbTemplate。我想知道如何使用 Query 执行此操作。

Query query = new Query();
Run Code Online (Sandbox Code Playgroud)

谁能告诉我我该怎么做。

mongodb spring-data-mongodb

13
推荐指数
4
解决办法
1万
查看次数

如何在 GraphQL Java 中解析多个模式文件

我正在将 GraphQL 与 java 一起使用。我有几个要解析的模式文件。任何人都可以让我知道是否有办法做到这一点。我使用了下面的方法,它只允许解析一个模式文件。

@Value("classpath:dashboard.graphql")
private Resource schemaResource;

File schemaFile = schemaResource.getFile();
TypeDefinitionRegistry definitionRegistry = new SchemaParser().parse(schemaFile);
Run Code Online (Sandbox Code Playgroud)

假设我有两个模式文件,例如dashboard.graphqlstudent.graphql。那么我们如何解析这两个文件呢?

任何人都可以请解释我。

谢谢

java graphql graphql-java

4
推荐指数
2
解决办法
6156
查看次数

如何从scala中的RDD中获取最早的时间戳日期

我有一个RDD就好((String, String), TimeStamp).我有大量的记录,我想为每个键选择具有最新TimeStamp值的记录.我已经尝试了以下代码,仍然在努力解决这个问题.任何人都可以帮我这样做吗?

我尝试下面的代码是错误的,不能正常工作

val context = sparkSession.read.format("jdbc")
  .option("driver", "com.mysql.jdbc.Driver")
  .option("url", url)
  .option("dbtable", "student_risk")
  .option("user", "user")
  .option("password", "password")
  .load()
context.cache();

val studentRDD = context.rdd.map(r => ((r.getString(r.fieldIndex("course_id")), r.getString(r.fieldIndex("student_id"))), r.getTimestamp(r.fieldIndex("risk_date_time"))))
val filteredRDD = studentRDD.collect().map(z => (z._1, z._2)).reduce((x, y) => (x._2.compareTo(y._2)))
Run Code Online (Sandbox Code Playgroud)

scala mapreduce apache-spark

3
推荐指数
1
解决办法
1341
查看次数

身份验证在spring boot 1.5.2和Oauth2中不起作用

我正在使用Oauth2和spring boot 1.5.2.RELEASE.当我试图覆盖ResourceServerConfigurerAdapter类的configure方法时,它给我一个编译错误.但是这对Spring boot 1.2.6.RELEASE工作正常.

以下是我的代码,

@Override
public void configure(HttpSecurity http) throws Exception {
    http
        .exceptionHandling()
        .authenticationEntryPoint(customAuthenticationEntryPoint)
        .and()
        .logout()
        .logoutUrl("/oauth/logout")
        .logoutSuccessHandler(customLogoutSuccessHandler)
        .and()
        .csrf()
        .requireCsrfProtectionMatcher(new AntPathRequestMatcher("/oauth/authorize"))
        .disable()
        .headers()
        .frameOptions().disable()
        .sessionManagement()
        .sessionCreationPolicy(SessionCreationPolicy.STATELESS)
        .and()
        .authorizeRequests()
        .antMatchers("/hello/").permitAll()
        .antMatchers("/secure/**").authenticated();
}
Run Code Online (Sandbox Code Playgroud)

上面的代码在Spring Boot 1.2.6中工作正常,但是当我尝试在1.5.2版本中调用sessionManagement()方法时出现编译错误.我想这个方法已在新版本中删除.

但是当我尝试使用disable().和().sessionManagement()时,编译错误会被删除,但身份验证不能按预期工作.任何人都可以帮我解决这个问题.

以下是我的完整代码

@Configuration
public class OAuth2Configuration {

    @Configuration
    @EnableResourceServer
    @ComponentScan(basePackages = "security")
    protected static class ResourceServerConfiguration extends ResourceServerConfigurerAdapter {

        @Autowired
        private CustomAuthenticationEntryPoint customAuthenticationEntryPoint;

        @Autowired
        private CustomLogoutSuccessHandler customLogoutSuccessHandler;

        @Override
        public void configure(HttpSecurity http) throws Exception {

            http
                .exceptionHandling()
                .authenticationEntryPoint(customAuthenticationEntryPoint)
                .and()
                .logout()
                .logoutUrl("/oauth/logout")
                .logoutSuccessHandler(customLogoutSuccessHandler) …
Run Code Online (Sandbox Code Playgroud)

spring spring-security oauth-2.0 spring-boot spring-security-oauth2

2
推荐指数
1
解决办法
3744
查看次数