diff --git a/job_scheduler.module b/job_scheduler.module
index c5009e2..7715ac2 100644
--- a/job_scheduler.module
+++ b/job_scheduler.module
@@ -48,7 +48,7 @@ function job_scheduler_cron() {
   }
 
   // Reschedule stuck periodic jobs after one hour.
-  db_update('job_schedule')
+  \Drupal::database()->update('job_schedule')
     ->fields(array(
       'scheduled' => 0,
     ))
@@ -61,7 +61,7 @@ function job_scheduler_cron() {
   $start = time();
   $total = 0;
   $failed = 0;
-  $jobs = db_select('job_schedule', NULL, array('fetch' => PDO::FETCH_ASSOC))
+  $jobs = \Drupal::database()->select('job_schedule', NULL, array('fetch' => PDO::FETCH_ASSOC))
     ->fields('job_schedule')
     ->condition('scheduled', 0)
     ->condition('next', REQUEST_TIME, '<=')
diff --git a/modules/job_scheduler_trigger/job_scheduler_trigger.admin.inc b/modules/job_scheduler_trigger/job_scheduler_trigger.admin.inc
index 584f662..9f00e3e 100644
--- a/modules/job_scheduler_trigger/job_scheduler_trigger.admin.inc
+++ b/modules/job_scheduler_trigger/job_scheduler_trigger.admin.inc
@@ -137,7 +137,7 @@ function job_scheduler_trigger_edit_form_submit($form, &$form_state) {
     }
   }
   elseif ($op == t('Delete')) {
-    db_delete('job_scheduler_trigger')
+    \Drupal::database()->delete('job_scheduler_trigger')
       ->condition('trid', $trigger['trid'])
       ->execute();
     drupal_set_message(t('The trigger has been deleted.'));
diff --git a/modules/job_scheduler_trigger/job_scheduler_trigger.module b/modules/job_scheduler_trigger/job_scheduler_trigger.module
index f969dc2..a3c327f 100644
--- a/modules/job_scheduler_trigger/job_scheduler_trigger.module
+++ b/modules/job_scheduler_trigger/job_scheduler_trigger.module
@@ -88,7 +88,7 @@ function job_scheduler_trigger_cron_job_scheduler_info() {
  * Get job list for job scheduler
  */
 function job_scheduler_trigger_list() {
-  return db_select('job_scheduler_trigger', 't')
+  return \Drupal::database()->select('job_scheduler_trigger', 't')
     ->fields('t')
     ->orderBy('status', 'DESC')
     ->execute()->fetchAll();
@@ -99,7 +99,7 @@ function job_scheduler_trigger_list() {
  */
 function job_scheduler_trigger_worker($job) {
   // Mark last time triggered for the records
-  db_update('job_scheduler_trigger')
+  \Drupal::database()->update('job_scheduler_trigger')
     ->fields(array('last' => REQUEST_TIME))
     ->condition('trid', $job['id'])
     ->execute();
@@ -119,7 +119,7 @@ function job_scheduler_trigger_worker($job) {
  * Menu loader
  */
 function job_scheduler_trigger_load($trid) {
-  return db_select('job_scheduler_trigger', 't')
+  return \Drupal::database()->select('job_scheduler_trigger', 't')
     ->fields('t')
     ->condition('trid', $trid)
     ->execute()->fetchObject();