Search

'insert'에 해당되는 글 3건

  1. 2013.04.28 JAVA MYSQL 활용 3
  2. 2013.04.27 JAVA MYSQL 활용 1
  3. 2013.03.02 JAVA executeQuery INSERT DELETE

JAVA MYSQL 활용 3

Programming/JAVA,JSP 2013. 4. 28. 14:20 Posted by TanSanC
336x280(권장), 300x250(권장), 250x250, 200x200 크기의 광고 코드만 넣을 수 있습니다.
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import org.restlet.Application;
import org.restlet.Request;
import org.restlet.Response;
import org.restlet.Restlet;
import org.restlet.Server;
import org.restlet.data.MediaType;
import org.restlet.data.Protocol;
import org.restlet.routing.Router;

public class test extends Application{
	public static Connection makeConnection() {
		String url = "jdbc:mysql://localhost/book_db";
		String id = "root";
		String password = "green";
		Connection con = null;
		try {
			Class.forName("com.mysql.jdbc.Driver");
			System.out.println("드라이버 적재 성공");
			con = DriverManager.getConnection(url, id, password);
			System.out.println("데이터베이스 연결 성공");
		} catch (ClassNotFoundException e) {
			System.out.println("드라이버를 찾을 수 없습니다.");
		} catch (SQLException e) {
			System.out.println("연결에 실패하였습니다.");
		}
		return con;
	}
	public static Statement stmt;
	public static void main(String[] args) throws Exception {
		Connection con = makeConnection();
		stmt = con.createStatement();
		Server server = new Server(Protocol.HTTP, 8182);
		server.setNext(new test());
		server.start();
	}
	public static String selectBooks(Statement stmt) throws SQLException {
		ResultSet rs = stmt.executeQuery("SELECT * FROM books");
		String result = "";
		while (rs.next()) {
			int id = rs.getInt("book_id");
			String title = rs.getString("title");
			String publisher = rs.getString("publisher");
			String year = rs.getString("year");
			if( title != null)
			{
				result += id + " " + title +" " + publisher +" " + year + "\n";
			}
		}
		return result;
	}
	public static String selectBooks(Statement stmt, String name) throws SQLException {
		ResultSet rs = stmt.executeQuery("SELECT * FROM books WHERE publisher = '" + name + "'");
		String result = "";
		while (rs.next()) {
			int id = rs.getInt("book_id");
			String title = rs.getString("title");
			String publisher = rs.getString("publisher");
			String year = rs.getString("year");
			if( title != null)
			{
				result += id + " " + title +" " + publisher +" " + year + "\n";
			}
		}
		return result;
	}
	@Override
	public Restlet createInboundRoot() {
		Router router = new Router();
		router.attach("http://localhost:8182/books", restlet1);
		router.attach("http://localhost:8182/books/where/{name}", restlet2);
		router.attach("http://localhost:8182/books/insert/{title}/{publisher}/{year}/{price}", restlet3);
		//(title, publisher, year, price)
		return router;
	}

	public Restlet restlet3 = new Restlet(getContext()) {
		@Override
		public void handle(Request request, Response response) {
			// Print the user name of the requested orders
			String title = (String)request.getAttributes().get("title");
			String publisher = (String)request.getAttributes().get("publisher");
			String year = (String)request.getAttributes().get("year");
			String price = (String)request.getAttributes().get("price");
			try {
				insertBooks(stmt,title,publisher,year,price);
			} catch (SQLException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
			String message = "";
			try {
				message += selectBooks(stmt);
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			response.setEntity(message, MediaType.TEXT_PLAIN);
		}

		private void insertBooks(Statement stmt, String title,
				String publisher, String year, String price) throws SQLException {
			// TODO Auto-generated method stub
			//INSERT INTO books (title, publisher, year, price)
			//VALUES('Operating System Concepts', 'Wiley', '2003', 30700);
			stmt.execute("INSERT INTO books (title, publisher, year, price)"
					+"VALUES('"+title+"','"+publisher+"','"+year+"',"+price+");");
		}
	};

	public Restlet restlet2 = new Restlet(getContext()) {
		@Override
		public void handle(Request request, Response response) {
			// Print the user name of the requested orders
			String name = (String)request.getAttributes().get("name");
			String message = "";
			try {
				message += selectBooks(stmt, name);
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			response.setEntity(message, MediaType.TEXT_PLAIN);
		}
	};
	public Restlet restlet1 = new Restlet() {
		public void handle(Request request, Response response) {
			String message = "";
			try {
				message += selectBooks(stmt);
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			response.setEntity(message, MediaType.TEXT_PLAIN);
		}
	};
}

'Programming > JAVA,JSP' 카테고리의 다른 글

JAVA MYSQL ANDROID REST 활용  (0) 2013.04.28
JAVA MYSQL 활용 4 Android App  (0) 2013.04.28
MYSQL REST 실습 코드 2  (0) 2013.04.28
MYSQL & REST 실습 코드  (0) 2013.04.28
JAVA MYSQL 활용 1  (0) 2013.04.27

JAVA MYSQL 활용 1

Programming/JAVA,JSP 2013. 4. 27. 17:08 Posted by TanSanC
336x280(권장), 300x250(권장), 250x250, 200x200 크기의 광고 코드만 넣을 수 있습니다.

1. 데이터 삽입 INSERT


INSERT INTO books (title, publisher, year, price)

  VALUES('Operating System Concepts', 'Wiley', '2003', 30700);

INSERT INTO books (title, publisher, year, price)

  VALUES('Head First PHP and MYSQL', 'OReilly', '2009', 58000);

INSERT INTO books (title, publisher, year, price)

  VALUES('C Programming Language', 'Prentice-Hall', '1989', 35000);

INSERT INTO books (title, publisher, year, price)

  VALUES('Head First SQL', 'OReilly', '2007', 43700);



2. 데이터 확인 

(지난 코드 재실행)



'Programming > JAVA,JSP' 카테고리의 다른 글

MYSQL REST 실습 코드 2  (0) 2013.04.28
MYSQL & REST 실습 코드  (0) 2013.04.28
JAVA MYSQL Test  (0) 2013.04.27
JAVA 코드 그럴듯 하게 보이게 하기?!  (1) 2013.04.27
restlet download restlet-jse-2.1.2  (0) 2013.04.27

JAVA executeQuery INSERT DELETE

Programming/JAVA,JSP 2013. 3. 2. 12:25 Posted by TanSanC
336x280(권장), 300x250(권장), 250x250, 200x200 크기의 광고 코드만 넣을 수 있습니다.

JAVA 에서

executeQuery 는 SELECT 시 사용됨


INSERT, DELETE 는

executeUpdate 를 사용함 


executeQuery 는 resultSet을 생성

executeUpdate 는 resultSet 대신 0과 1로 성공적으로 수행되었는지를 반환


예제 코드

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JDBCEexecuteExample {
       
public static void main(String[] args) throws SQLException {
               
Connection connection = null; // connection reference variable for
                                                                               
// getting
               
// connection
               
Statement statement = null; // Statement reference variable for query
               
// Execution
               
ResultSet resultSet = null; // ResultSet reference variable for saving
                                                                       
// query
               
// result
               
String conUrl = "jdbc:mysql://localhost:3306/";
               
String driverName = "com.mysql.jdbc.Driver";
               
String databaseName = "student";
               
String usrName = "root";
               
String usrPass = "root";
               
try {
                       
// Loading Driver
                       
Class.forName(driverName);
               
} catch (ClassNotFoundException e) {
                       
System.out.println(e.toString());
               
}
               
try {
                       
// Getting Connection
                        connection
= DriverManager.getConnection(conUrl + databaseName,
                                        usrName
, usrPass);
                       
// setting connection autocommit false
                        connection
.setAutoCommit(false);
                       
// Getting reference to connection object
                        statement
= connection.createStatement();
                       
// creating Query String
                       
String updateQuery = "UPDATE student SET NAME='Rajan' WHERE RollNo=1";
                       
String selectQuery = "SELECT * FROM student";
                       
String insertQuery = "INSERT INTO student values(4,'Rohan','MCA','Mumbai')";
                       
String deleteQuery = "DELETE FROM student WHERE RollNo=4";
                       
// Insert Query
                        statement
.executeUpdate(insertQuery);
                       
// Updating Query
                       
int result = statement.executeUpdate(updateQuery);
                       
if (result == 1) {
                               
System.out.println("Table Updated Successfully.......");
                       
}
                       
// Delete Query
                        statement
.executeUpdate(deleteQuery);
                       
// excecuting query
                        resultSet
= statement.executeQuery(selectQuery);
                       
while (resultSet.next()) {
                               
// Didplaying data of tables
                               
System.out.println("Roll No " + resultSet.getInt("RollNo")
                                               
+ ", Name " + resultSet.getString("Name") + ", Course "
                                               
+ resultSet.getString("Course") + ", Address "
                                               
+ resultSet.getString("Address"));
                       
}
               
} catch (Exception e) {
                       
System.out.println(e.toString());
               
} finally {
                       
// Closing connection
                        resultSet
.close();
                        statement
.close();
                        connection
.close();
               
}
       
}
}

'Programming > JAVA,JSP' 카테고리의 다른 글

JAVA 삽입 정렬  (0) 2013.03.03
JAVA JTABLE 사용 예제  (0) 2013.03.03
JAVA 데이터베이스 실습 예제 UI  (0) 2013.02.24
JAVA JDBC 튜토리얼 예제 사이트  (0) 2013.02.24
JAVA 채팅 프로그램 + GUI  (0) 2013.02.23