Question

기존 이메일이있는 경우 사용자 을 추가하지 마십시오. 기존 이메일이없는 경우 사용자를 추가하십시오.

하나의 API가 모든 것을 처리하므로 두 API, User API 및 Database API로 API를 분리하려고합니다.

내가

"쿼리"와 같은 JSON을 사용하여 쿼리를 보낼 경우

["SELECT * FROM USER WHERE email='" + email + "'", 
"INSERT INTO USER VALUES('" + email + "', '" + name + "', '" + password + "')"] 

및 데이터베이스 API가 동시에 그 쿼리를 처리해야합니다. SELECT에서 결과가 있다면

는 INSERT

vertx에서 어떤 해결책이 있나요, INSERT 그렇지 않은 경우에는하지 않는합니까?

미리 감사드립니다.

connection.query("SELECT * FROM USER WHERE email='" + email + "'", rs -> { 
    if(!rs.result().getResults().isEmpty()) { 
     handler.handle(Future.failedFuture("email already exists")); 
    } else { 
     connection.execute("INSERT INTO USER VALUES('" + email + "', '" + name + "', '" + password + "')", ins -> { 

      if (ins.failed()) { 
       throw new RuntimeException(ins.cause()); 
      } 

      // and close the connection 
      connection.close(done -> { 
       if (done.failed()) { 
        throw new RuntimeException(done.cause()); 
       } 
      }); 
     }); 
     handler.handle(Future.succeededFuture(new JsonObject().put("result", "succeed"))); 
    } 
}); 

Answer 1

우선, 실제로 API에 쿼리를 보내지 않고 SQL 주입을 방지하기 위해 준비된 문을 사용하고 싶습니다.

둘째, 이메일 열에 고유 한 키를 추가 한 다음 예외를 잡아서 Vert.x의 개입없이 문제를 해결할 수 있습니다. 응용 프로그램에서

alter table USER add unique (email) 

:

JsonArray params = new JsonArray().add("a@a.com").add("A").add("abcd"); 
conn.updateWithParams("insert into user (email, name, password) values (?, ?, ?)", params, 
     (r) -> { 
      if (r.succeeded()) { 
       System.out.println("Ok!"); 
      } 
      else { 
       if (r.cause() instanceof MySQLException) { 
        MySQLException cause = (MySQLException) r.cause(); 
        // 1062 is MySQL Duplicate Key 
        if (cause.errorMessage().errorCode() == 1062) { 
         // Duplicate key, ignore 
        } 
       } 
      } 
      // Handle connection closing 
}); 

당신의 DB에서