Chạy sql liệu bên trong mẫu: Laravel

Question

Tôi đang sử dụng Laravel và cần phải chạy truy vấn sql liệu từ một mô hình/lớp Repository

INSERT INTO calendar 
(room_id, date, default_count, default_price) 
VALUES ('1', '2017-01-02', '2', '400004') 
ON DUPLICATE KEY UPDATE 
default_count = VALUES(default_count), default_price = VALUES(default_price); 

cũ. Khi tôi chèn dữ liệu từ UserRepository

$this->users->insert(['email' => 'john@example.com', 'votes' => 0]); 

Tôi cần một số loại phương pháp để có được kết nối DB và chạy sql qua mô hình

//Something like 
$this->users->execute($sql); 

tôi thấy Laravel có updateOrInsert() phương pháp nhưng tôi cần phải chạy này cho nhiều dữ liệu đặt cùng một lúc.

Làm cách nào để chạy truy vấn sql thô thông qua lớp mô hình hoặc kho lưu trữ?

Cảm ơn

CẬP NHẬT - SOLVED

tôi đã đi qua Eloquent Model Sourcecode và thấy tôi có thể nhận được phương pháp()

$this->users->getConnection()->statement($sql); 

Answer 1

tôi đã đi qua hùng biện Mẫu mã nguồn và thấy tôi có thể nhận kết nối từ getConnection phương pháp()

$this->users->getConnection()->statement($sql); 

không biết statement() là cách tốt nhất để chạy sql này. Tuy nhiên nó đã hoạt động.

Cảm ơn mọi người đã trợ giúp. Ngoài ra nếu bạn có giải pháp tốt hơn, vui lòng cho tôi biết

Answer 2

Làm như thế này

$query = array(['room_id' => 1, 'date' => '2/1/2017', 'default_count' => '2', 'default_price' => '400004'], 
['room_id' => 2, 'date' => '2/1/2017', 'default_count' => '3', 'default_price' => '455004']); 


DB::table('calendar')->insart('query'); 

kết nối từ getConnection Và al vì vậy bạn có thể làm như thế này, Tạo obj của phương thức và gán giá trị

$obj_calendar = new Calendar(); 
$obj_calendar->room_id = 1; 
$obj_calendar->date = date('Y-m-d H:i:s', strtotime('2017-01-02')); 
$obj_calendar->default_count = 2; 
$obj_calendar->default_price = 400004; 
$obj_calendar->save(); 

---

Sử dụng giao dịch

// bắt đầu giao dịch

public function beginTransaction() 
{ 
    DB::beginTransaction(); 
} 

// thực hiện giao dịch

public function makeTransaction($query) 
{ 
    DB::transaction(function($query) use($query) 
    { 
    DB::insert($query); 
    }); 
} 

// cam kết giao dịch

public function commitTransaction() 
{ 
    return DB::commit(); 
} 

Trong phương pháp của bạn

public function insert($data) 
{ 
    $this->beginTransaction(); 

    for($i=0; $i<count($data); $i++) 
    { 
    $name = $data[$i]->first_name, "middle_name" => $data[$i]->middle_name, "last_name" => $data[$i]->last_name; 

    $query = "INSERT INTO tbl_name(id, first_name, description, created_at, updated_at) VALUES (" . $data[$i]->id . ", " . $name . ", '" . $data[$i]->description . "', '" . date("Y-m-d H:i:s",strtotime($data[$i]->created_at)) . "', '" . date("Y-m-d H:i:s",strtotime($data[$i]->created_at)) . "'); "; 

    $scraper_service->makeTransaction($query); 
    } 

    //Add last commit 
    $this->commitTransaction(); 
}