Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import java.io.BufferedReader;
- import java.io.IOException;
- import java.io.InputStream;
- import java.io.InputStreamReader;
- import java.sql.Connection;
- import java.sql.DatabaseMetaData;
- import java.sql.DriverManager;
- import java.sql.ResultSet;
- import java.sql.ResultSetMetaData;
- import java.sql.SQLException;
- import java.sql.Statement;
- import java.util.StringTokenizer;
- public class SqlClient {
- /**
- * @param args
- */
- public static void main(String[] args) {
- if(args.length<2) {
- System.out.println("RTFM DUDE!");
- return;
- }
- String url = "jdbc:mysql://" + args[0] + "/";
- String database = args[1];
- Connection connection;
- Statement statement;
- try {
- Class.forName("org.gjt.mm.mysql.Driver");
- } catch (ClassNotFoundException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- try {
- connection = DriverManager.getConnection(url+database,"root","");
- while (true) {
- BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
- String polecenie = br.readLine();
- StringTokenizer st = new StringTokenizer(polecenie);
- String which = st.nextToken();
- if (which.equals("INSERT") || which.equals("UPDATE")
- || which.equals("DELETE")) {
- statement = connection.createStatement();
- statement.executeUpdate(polecenie);
- statement.close();
- }
- else if (which.equals("SELECT")) {
- statement = connection.createStatement();
- ResultSet rs = statement.executeQuery(polecenie);
- ResultSetMetaData rsmd = rs.getMetaData();
- int nrWiersza = 1;
- while(rs.next()) {
- System.out.println("Wiersz " + nrWiersza + ": ");
- for (int i = 1; i <= rsmd.getColumnCount(); i++)
- {
- System.out.print(" Kolumna " + i + ": ");
- //Ponizsza instrukcja wypisuje zawartosc kolumny o numerze i z obrabianego
- System.out.println(rs.getString(i));
- }
- System.out.println("");
- nrWiersza++;
- }
- }
- else if (which.equals("USE")) {
- st.nextToken();
- database = st.nextToken();
- connection = DriverManager.getConnection(url+database,"root","");
- }
- else if (which.equals("SHOW")) {
- DatabaseMetaData dmd = connection.getMetaData();
- ResultSet rs = dmd.getTables(null, null, "%", null);
- while(rs.next()) {
- System.out.println(rs.getString("TABLE_NAME"));
- }
- }
- else if (which.equals("DESCRIBE")) {
- st.nextToken();
- String name = st.nextToken();
- statement = connection.createStatement();
- ResultSet rs = statement.executeQuery("select * from " + name);
- ResultSetMetaData rsmd = rs.getMetaData();
- int iloscKolumn = rsmd.getColumnCount();
- for (int i = 1; i <= iloscKolumn; i++)
- {
- //Nazwa kolumny
- String nazwaKolumny = rsmd.getColumnName(i);
- String nazwaTabeli = rsmd.getTableName(i);
- String nazwaTypu = rsmd.getColumnTypeName(i);
- boolean caseSen = rsmd.isCaseSensitive(i);
- boolean moznaPisac = rsmd.isWritable(i);
- System.out.println("Informacja o kolumnie " + nazwaKolumny);
- System.out.println(" Kolumna z tabeli " + nazwaTabeli);
- System.out.println(" Typ kolumny " + nazwaTypu);
- System.out.println(" Case sensitive: " + caseSen);
- System.out.println(" Mozna zapisywac: " + moznaPisac);
- System.out.println("");
- }
- }
- }
- } catch (SQLException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement