diff --git a/install/removeRepeatedPlaylists.php b/install/removeRepeatedPlaylists.php new file mode 100644 index 0000000000..4cfe3e32e9 --- /dev/null +++ b/install/removeRepeatedPlaylists.php @@ -0,0 +1,70 @@ + $row) { + $users_ids[] = $row['users_id']; + } +} else { + die($sql . '\nError : (' . $global['mysqli']->errno . ') ' . $global['mysqli']->error); +} + + +foreach ($users_ids as $user_id) { + echo "Process user_id = {$user_id}\n"; + ob_flush(); + $sql = "SELECT * FROM playlists WHERE users_id = {$user_id} AND status = 'favorite' ORDER BY created "; + $res = sqlDAL::readSql($sql); + $fullData = sqlDAL::fetchAllAssoc($res); + sqlDAL::close($res); + $rows = array(); + if ($res != false) { + foreach ($fullData as $key => $row) { + if ($key === 0) { + continue; + } + $sql = "DELETE FROM playlists "; + $sql .= " WHERE id = ?"; + + echo $sql." = {$row['id']}\n"; + ob_flush(); + sqlDAL::writeSql($sql, "i", array($row['id'])); + } + } else { + die($sql . '\nError : (' . $global['mysqli']->errno . ') ' . $global['mysqli']->error); + } + + + $sql = "SELECT * FROM playlists WHERE users_id = {$user_id} AND status = 'watch_later' ORDER BY created "; + $res = sqlDAL::readSql($sql); + $fullData = sqlDAL::fetchAllAssoc($res); + sqlDAL::close($res); + $rows = array(); + if ($res != false) { + foreach ($fullData as $key => $row) { + if ($key === 0) { + continue; + } + $sql = "DELETE FROM playlists "; + $sql .= " WHERE id = ?"; + echo $sql." = {$row['id']}\n"; + ob_flush(); + sqlDAL::writeSql($sql, "i", array($row['id'])); + } + } else { + die($sql . '\nError : (' . $global['mysqli']->errno . ') ' . $global['mysqli']->error); + } + +}