Làm cách nào để chạy truy vấn MySQL không đồng bộ/không chặn trong khung Chơi?

Question

Chỉ mới bắt đầu trên Play. Tài liệu nói về cách Play có thể chạy không đồng bộ.

Nhưng cách chạy truy vấn MySQL khi chạy Play không đồng bộ? Các truy vấn MySQL bình thường đang chặn, phải không? Vì vậy, điều đó sẽ không hoạt động.

Node.js có các máy khách MySQL không chặn riêng của nó chỉ cho mục đích này, nhưng tôi không thể tìm thấy bất kỳ điều gì tương tự cho Play.

Làm thế nào để bạn chạy các truy vấn MySQL trong một ứng dụng Play không đồng bộ?

Answer 1

xem liên kết này Asynchronous jobs trong khung chơi.

Answer 2

Công việc phát được thực hiện trong một chuỗi riêng biệt và giải phóng chuỗi http chính. Sau đó, chuỗi http chính bắt đầu khi nó bị bỏ đi khi công việc (được bao bọc trong một đối tượng Promise) trả về sau khi hoàn thành.

Vì vậy, chuỗi http chính không được giữ và có thể sẵn có để xử lý các yêu cầu http đến khác.

Answer 3

Trong việc thực hiện chung các cuộc gọi SQL tới DB thường bị chặn và được thực hiện tuần tự. Play có hỗ trợ tuyệt vời cho việc thực thi Không đồng bộ giúp cải thiện hiệu suất của ứng dụng của bạn.

Làm việc mẫu mã cho Chơi 2,0

public static Result slow() { 
    Logger.debug("slow started"); 

    // Start execution 
    Promise<DataObject> userObject1 = SlowQuery.getUser(440); 
    Promise<DataObject> userObject2 = SlowQuery.getCategory(420); 
    // ... here execution is already in progress ... 

    // Map to Promise Objects 
    Promise<DataObject> res1 = userObject1.map(new Function<DataObject, DataObject>() { 
     public DataObject apply(DataObject res) { 
      Logger.debug("Got result (userObject1): " + res.toString()); 
      return res; 
     } 
    }); 

    Promise<DataObject> res2 = userObject2.map(new Function<DataObject, DataObject>() { 
     public DataObject apply(DataObject res) { 
      Logger.debug("Got result (userObject2): " + res.toString()); 
      return res; 
     } 
    }); 

    // here we wait for completion - this blocks 
    userObject1.getWrappedPromise().await(); 
    userObject2.getWrappedPromise().await(); 

    // the result is available 
    Logger.debug(res1.get().toString()); 
    Logger.debug(res2.get().toString()); 

    Logger.debug("slow finished"); 
    return ok("done"); 
} 

cảm thấy tự do để nâng cao sử dụng tính năng cộng đồng wiki - Tôi chắc chắn một số bộ phận có thể được rút ngắn.

Answer 4

Bạn nên cân nhắc việc sử dụng trình kết nối MySQL không chặn. Ví dụ. https://code.google.com/p/async-mysql-connector/