Charts V1

zecke.go

@@ -85,3 +85,29 @@ func MmReadOracle() ([]MmOracle, error) {
 
 	return oracles, err
 }
+
+func MmReadCharts() ([]MmOracle, error) {
+	chartsQuery := `SELECT m.id, m.title, m.mal_id FROM movie m
+	JOIN evening_movie em ON em.movie_id = m.id
+	JOIN evening e ON em.evening_id = e.id
+	WHERE e.date <= CURDATE() AND m.mal_id IS NOT NULL;`
+	rows, err := mmDb.Query(chartsQuery)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+
+	charts := make([]MmOracle, 0)
+	for rows.Next() {
+		var chart MmOracle
+		err = rows.Scan(&chart.Id, &chart.Title, &chart.Anime)
+		if err != nil {
+			return charts, err
+		}
+		charts = append(charts, chart)
+	}
+
+	err = rows.Err()
+
+	return charts, err
+}