Bagaimana cara mendapatkan data dari mysql ke notebook jupyter?

SQL adalah keterampilan yang sangat penting. Anda tidak hanya dapat mengakses database relasional tetapi juga data besar menggunakan

%%sql
insert into config_test values("sandeep", 20);
insert into config_test values("sandeep", 30);
insert into config_test values("giri", 10)

%%sql
insert into config_test values("sandeep", 20);
insert into config_test values("sandeep", 30);
insert into config_test values("giri", 10)

Notebook Jupyter adalah alat yang hebat untuk analitik dan komputasi interaktif. Anda dapat berinteraksi dengan berbagai alat seperti Python, Linux, File System, Scala, Lua, Spark, R, dan SQL dari kenyamanan browser. Untuk hampir setiap alat interaktif, ada kernel di Jupyter. Mari kita telusuri bagaimana Anda akan menggunakan

%%sql
insert into config_test values("sandeep", 20);
insert into config_test values("sandeep", 30);
insert into config_test values("giri", 10)

Instalasi

Kernel yang akan kita gunakan adalah ipython-sql. Jika Anda menggunakan lingkungan CloudxLab, Anda tidak perlu menginstal apapun. Anda cukup membuka notebook "Python 3" dan mulai dengan istirahat

Jika Anda tidak menggunakan CloudxLab, Anda harus menginstal ipython-sql menggunakan perintah berikut

%%sql
insert into config_test values("sandeep", 20);
insert into config_test values("sandeep", 30);
insert into config_test values("giri", 10)

Sekarang, buat notebook baru menggunakan Jupyter, New -> "Python 3" di CloudxLab

Muat Ekstensi

Hal pertama yang perlu Anda lakukan adalah memuat ekstensi. Jalankan perintah berikut di notebook Jupyter

%%sql
insert into config_test values("sandeep", 20);
insert into config_test values("sandeep", 30);
insert into config_test values("giri", 10)

Berinteraksi dengan SQLite

SQLite adalah database ringan yang hebat. Dari situs web mereka, deskripsi ini sangat tepat

Format file SQLite stabil, lintas platform, dan kompatibel dengan versi sebelumnya, dan developer berjanji untuk mempertahankannya hingga tahun 2050. File database SQLite biasanya digunakan sebagai wadah untuk mentransfer konten kaya antar sistem [1][2][3] dan sebagai format arsip jangka panjang untuk data [4]

www. sqlite. org

Inisialisasi koneksi

Setelah Anda memuat ekstensi

%%sql
insert into config_test values("sandeep", 20);
insert into config_test values("sandeep", 30);
insert into config_test values("giri", 10)

%%sql
insert into config_test values("sandeep", 20);
insert into config_test values("sandeep", 30);
insert into config_test values("giri", 10)

Ini akan membuat file database dengan nama

%%sql
insert into config_test values("sandeep", 20);
insert into config_test values("sandeep", 30);
insert into config_test values("giri", 10)

Buat Tabel di SQLite

Mari buat tabel sederhana `config_test` dengan dua kolom – nama dan nilai

 %%sql
 create table config_test(name varchar(20), value int) 

Harap perhatikan '%' dua kali sebelum 'sql'. Sebelumnya kami hanya menggunakan satu '%'

Masukkan data ke dalam tabel di SQLite

Kita bisa memasukkan data ke dalam tabel yang dibuat sebelumnya menggunakan perintah SQL standar

%%sql
insert into config_test values("sandeep", 20);
insert into config_test values("sandeep", 30);
insert into config_test values("giri", 10)

Dalam sel SQL di notebook Jupyter, Anda dapat menambahkan beberapa pernyataan SQL. Harap pastikan untuk mengakhiri setiap pernyataan dengan titik koma. Meskipun Anda dapat melewati titik koma pada pernyataan terakhir sel

Meminta tabel SQLite

Tentu saja, Anda dapat membuat kueri menggunakan SQL kompleks di SQLite. Pernyataan pilih juga mengharuskan Anda memulai sel dengan %%sql

%%sql
select * from config_test

Anda dapat menulis kueri kompleks apa pun di dalam sel. Ini akan menampilkan hasil dalam format berikut

Ini adalah contoh kueri lainnya

%%sql
 select name, sum(value), count(value) from config_test group by name

Ini pada dasarnya mengelompokkan data berdasarkan nama dan menggabungkan nilainya

Untuk membantu Anda mempraktikkan SQL, kami telah memperbarui DB SQLite ke lokasi bersama. Kami telah menyalin file database dari. Anda dapat menggunakan database itu dengan perintah berikut

%sql sqlite:////cxldata/sqlite/sf-food-inspections-lives.sqlite

Harap perhatikan bahwa ada empat garis miring setelah “sqlite. ” di Url. Tiga garis miring pertama adalah bagian dari skema URL dan garis miring terakhir adalah untuk jalur absolut karena file database

%%sql
insert into config_test values("sandeep", 20);
insert into config_test values("sandeep", 30);
insert into config_test values("giri", 10)

%%sql
insert into config_test values("sandeep", 20);
insert into config_test values("sandeep", 30);
insert into config_test values("giri", 10)

Untuk mengetahui tabel mana yang ada di database ini, Anda dapat menggunakan perintah berikut. Perintah standar “. tables” dari konsol SQLite tidak akan berfungsi

%%sql
 SELECT name FROM sqlite_master WHERE type='table'

Ini akan mencetak

%%sql
select * from config_test

Sekarang, Anda dapat berlatih membuat kueri tabel ini. Ini adalah kueri sederhana

%%sql
select * from inspection_records limit 10;

Berinteraksi dengan MySQL menggunakan notebook Jupyter

Membangun koneksi

Di CloudxLab, kami sudah memiliki database MySQL yang terinstal. Detail yang dapat Anda temukan di

Jika Anda melakukannya di komputer lokal, Anda mungkin harus menginstal database MySQL dan driver mysql di notebook Jupyter

Hal pertama yang harus Anda lakukan adalah menginisialisasi koneksi

%sql mysql://sqoopuser:[email protected]/retail_db

Pada dasarnya, formal URL koneksi adalah mysql. //Gabung. password@host/namadatabase

Meminta MySQL

Sekarang, Anda dapat menjalankan kueri SQL seperti yang disebutkan di atas. Untuk mengetahui tentang tabel, Anda dapat menjalankan

%%sql
 show tables

Itu akan menampilkan sesuatu seperti ini

Untuk melihat apa yang ada di tabel `pelanggan`, Anda dapat menggunakan

%%sql
 select * from customers limit 10;

Anda dapat berinteraksi dengan database lain dengan cara yang sama. Anda harus menggunakan string koneksi yang berbeda. Silakan lihat dokumentasinya untuk lebih jelasnya

Bagaimana Anda menarik data ke notebook Jupyter?

Bagaimana cara mendapatkan data dari MySQL ke Python?

Bagaimana cara menjalankan kueri SQL di notebook Jupyter?

Bisakah Python mengakses database MySQL?