Inserting Data In Database table using Statement
In this program we are going to insert the data in the
database from our java program in the table stored in the database.
To accomplish our goal we first have to make a class
named as ServletInsertingData, which must extends the abstract HttpServlet
class, the name of the class should be such that other person can understand
what this program is going to perform. The logic of the program will be written
inside the doGet() method that takes two arguments, first is HttpServletRequest
interface and the second one is the HttpServletResponse interface
and this method can throw ServletException.
Inside this method call the getWriter() method
of the PrintWriter class. We can insert the data in the database only and
only if there is a connectivity between our database and the java program. To
establish the connection between our database and the java program we first
need to call the method forName(), which is static in nature of the class
Class. It takes one argument which tells about the database driver we are
going to use. Now use the static method getConnection() of the DriverManager
class. This method takes three arguments and returns the Connection
object. SQL statements are executed and results are returned within the
context of a connection. Now your connection has been established. Now use the
method createStatement() of the Connection object which will
return the Statement object. This object is used for executing a static
SQL statement and obtaining the results produced by it. We have to insert a
values into the table so we need to write a query for inserting the values into
the table. This query we will write inside the executeUpdate() method of
the Statement object. This method returns int value.
If the record will get inserted in the table then
output will show "record has been inserted" otherwise
"sorry! Failure".
The code of the program is given below:
import java.io.*;
import java.sql.*;
import javax.servlet.*;
import javax.servlet.http.*;
public class DataInsertion extends HttpServlet{
public void doGet(HttpServletRequest request, HttpServletResponse response)throws
ServletException, IOException{
response.setContentType("text/html");
PrintWriter out = response.getWriter();
String url = "jdbc:mysql://localhost/zulfiqar?user=root&password=admin";
Connection conn;
ResultSet rs;
try{
Class.forName("org.gjt.mm.mysql.Driver");
conn = DriverManager.getConnection(url);
Statement statement = conn.createStatement();
String query = "insert into emp_sal values('zulfiqar', 15000)";
int i = statement.executeUpdate(query);
if(i!=0){
out.println("The record has been inserted");
}
else{
out.println("Sorry! Failure");
}
rs = statement.executeQuery("select * from emp_sal");
while(rs.next()){
out.println("<p><table>" + rs.getString(1) + " " + rs.getInt(2) + "</p></table>");
}
rs.close();
statement.close();
}
catch (Exception e){
System.out.println(e);
}
}
}
|
XML File for this program
<?xml version="1.0" encoding="ISO-8859-1"?>
<!--<!DOCTYPE web-app
PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
"http://java.sun.com/dtd/web-app_2_3.dtd"> -->
<web-app>
<servlet>
<servlet-name>Hello</servlet-name>
<servlet-class>DataInsertion</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>Hello</servlet-name>
<url-pattern>/DataInsertion</url-pattern>
</servlet-mapping>
</web-app>
|
Table in the database before Insertion:
mysql> select * from emp_sal;
Empty set (0.02 sec) |
The output of the program is given below:
Table in the database after Insertion:
mysql> select * from emp_sal;
+----------+--------+
| EmpName | salary |
+----------+--------+
| zulfiqar | 15000 |
+----------+--------+
1 row in set (0.02 sec) |
Download this
example:
|
Del.icio.us
Digg
Google
Spurl
Blink
Furl
Simpy
Y! MyWeb
