当前位置:  技术问答>java相关

那位朋友可以给个applet通过servlet取数据库数据的例子?多谢!

    来源: 互联网  发布时间:2015-06-11

    本文导语:  多谢了。/ 我找以前的没找到有,只好又发了一贴,请多多帮忙。 | import java.io.*; import java.awt.*; import java.applet.*; public class DataBaseApplet extends Applet implements Runnable {   int i;   String respo...

多谢了。/
我找以前的没找到有,只好又发了一贴,请多多帮忙。

|
import java.io.*;
import java.awt.*;
import java.applet.*;

public class DataBaseApplet extends Applet implements Runnable
{
  int i;
  String response;
  Thread theThread;

  TextArea messInfo=new TextArea("",16,45);
  TextField txtDbIP=new TextField(30)
  ,txtPort=new TextField(4)
  ,txtUID=new TextField(10)
  ,txtPass=new TextField(10)
  ,txtSql=new TextField(30);
  Button btnConnect=new Button("Connect");

  public void init()
  {

this.setSize(500,300);

setLayout(new BorderLayout());
Panel mainPanel=new Panel();
Panel panel1=new Panel();
Panel panel2=new Panel();
Panel panel3=new Panel();

messInfo.setEditable(false);
add("North",messInfo);
//add("North",panel1);

panel2.add(new Label("DB IP:"));
panel2.add(txtDbIP);
panel2.add(new Label("Port:4444"));
panel2.add(txtPort);
add("Center",panel2);

panel3.add(new Label("username:"));
panel3.add(txtUID);
panel3.add(new Label("password:"));
panel3.add(txtPass);
panel3.add(btnConnect);
add("South",panel3);

theThread=new Thread(this);
  }    

  public void start()
  {
theThread.start();
  }    

  public void run()
  {

while(true)
{
  i++;
  this.req();

  // Graphics g=getGraphics();
  //g.drawString("read from server:"+this.response,10,20*i);
  //g.dispose();
  this.messInfo.append("read from server:"+this.response);
  try
  {
theThread.sleep(2000);
  }
  catch(InterruptedException e){}
}

  }      

  public void req()
  {
try
{
  java.net.URL url=
new java.net.URL(getDocumentBase(),"/servlet/DataBaseServlet");
  System.out.println("getDocumentBase(): "+getDocumentBase());
  java.net.URLConnection con = url.openConnection();
  con.setUseCaches(false);
  con.setDoOutput(true);
  con.setDoInput(true);
  
  ByteArrayOutputStream byteout=new ByteArrayOutputStream();
  DataOutputStream out=new DataOutputStream(byteout);
  out.writeUTF("Hello world!?");
  out.flush();
  
  byte buf[]=byteout.toByteArray();
  con.setRequestProperty("Content-type","application/octet-stream");
  con.setRequestProperty("Content-length",""+buf.length);
  
  DataOutputStream dataout=new DataOutputStream(con.getOutputStream());
  dataout.write(buf);
  dataout.flush();
  dataout.close();

  DataInputStream in=new DataInputStream(con.getInputStream());
  this.response=in.readUTF();
  //repaint();
  //System.out.println("read from server:"+response);

  in.close();
}
//catch(java.net.MalformedURLException e){}
catch(Exception e){
e.printStackTrace();
}
  }              

  public void paint(Graphics g)
  {
//g.drawString("read from server:"+this.response,10,20);
  }    
}
-----------------------------------------
import java.sql.*;
import javax.servlet.*;
import javax.servlet.http.*;
import java.io.*;
import java.util.*;


import javax.naming.*;import javax.sql.*;
public class DataBaseServlet extends HttpServlet{
  String respData;
  public void service(HttpServletRequest req,HttpServletResponse resp)
  {
try
{
  DataInputStream in=new DataInputStream(req.getInputStream());
  resp.setContentType("application/octet-stream");
  ByteArrayOutputStream byteout=new ByteArrayOutputStream();
  DataOutputStream out=new DataOutputStream(byteout);
  this.getDbData();
  String response=in.readUTF()+" "+this.respData+" "+this.nowTime()+"n";
  System.out.println(response);
  out.writeUTF(response);
  out.flush();
  byte buf[]=byteout.toByteArray();
  resp.setContentLength(buf.length);
  ServletOutputStream servletout=resp.getOutputStream();
  servletout.write(buf);
  servletout.close();
}
catch(java.io.IOException e){
e.printStackTrace();
}
  }                


  public void getDbData()
  {

  try
  {

String url="jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=MYDB";
String driver="com.microsoft.jdbc.sqlserver.SQLServerDriver";

   Class.forName(driver).newInstance();

   String login = "admin";
  String password = "password";
  Connection con=DriverManager.getConnection(url,login,password);

   Statement st = con.createStatement();
   ResultSet rs = st.executeQuery("SELECT * FROM customer");

   rs.next();
   this.respData=String.valueOf(rs.getInt("cust_id"))+"tttt";

   st.close();
   con.close();

  }
catch(java.sql.SQLException e){System.out.println(e.toString());}
catch(java.lang.ClassNotFoundException e){System.out.println(e.toString());}
catch(java.lang.InstantiationException e){System.out.println(e.toString());}
catch(java.lang.IllegalAccessException e){System.out.println(e.toString());}
  }            



  public String nowTime()
  {
java.util.Calendar currTimeCal=java.util.Calendar.getInstance();
int currDate=currTimeCal.get(Calendar.DATE);
int currYear=currTimeCal.get(Calendar.YEAR);
int currMonth=currTimeCal.get(Calendar.MONTH);
int currHour=currTimeCal.get(Calendar.HOUR_OF_DAY);
int currMinute=currTimeCal.get(Calendar.MINUTE);
int currSecond=currTimeCal.get(Calendar.SECOND);

String currTime=String.valueOf(currYear)
  +"-"+String.valueOf(currMonth)
  +"-"+String.valueOf(currDate)
  +":"+String.valueOf(currHour)
  +":"+String.valueOf(currMinute)
  +":"+String.valueOf(currSecond);


return currTime;
  }    
}

|
and clients site:

  private void defineOrgStruc(ArrayList levellist) throws MalformedURLException, IOException{
    URL url = new URL(/tech-qa-java/servleturl/index.html);
    URLConnection con = url.openConnection();
    con.setUseCaches(false);
    System.out.println(levellist.toString());
    try{
        ObjectOutputStream outputToServlet = null;
        con.setDoOutput(true);
        outputToServlet = new ObjectOutputStream(con.getOutputStream());
        outputToServlet.writeObject(levellist);
        outputToServlet.flush();
        outputToServlet.close();
       }catch (IOException se){
        JOptionPane.showMessageDialog(null, "Can not establish connection to server", "Connection failed", JOptionPane.PLAIN_MESSAGE);
        return;
      }

    try{
        InputStream in = con.getInputStream();
        ObjectInputStream objStream;
        objStream = new ObjectInputStream(in);
        objStream.readObject();
    }catch(Exception re){
      JOptionPane.showMessageDialog(null, "Can not establish connection to server", "Connection failed", JOptionPane.PLAIN_MESSAGE);
      return;
    }
    JOptionPane.showMessageDialog(null, "Structure is saved!");
 }

    
 
 

您可能感兴趣的文章:

  • 请问各位朋友:在JAVA的数据库应用管理系统中,如何不在操作系统忠建立数据源便能连接数据库(如ACCESS、MS SQL 等等
  • 怎么编程实现发送Ipv6携带扩展报头的数据包??对ipv6有研究的朋友进来帮帮忙?
  • 请有经验的朋友给个思路,关于通过ejb修改数据库记录。100分送上!bow
  • 请问各位朋友:在JAVA的数据库应用管理系统中,如何不在操作系统忠建立数据源便能连接数据库(如ACCESS、MS SQL 等等)?
  • 各位朋友,救救我,救救我硬盘中的数据……
  • 请问各位朋友:在JAVA的数据库应用管理系统中,如何不在操作系统忠建立数据源便能连接数据库(如ACCESS、MS SQL 等等)
  • 那位朋友有java类库手册?多谢了
  • 我想学jsp,请朋友们给推荐几本书!多谢了
  • 那位朋友帮忙看看这是什么意思?多谢
  • 哪位朋友有tomcat的培训资料呀?或者可以在哪里找到相关资料呢?多谢啦!
  • 一朋友需要mobileset3 (for jbuilder),我开贴子联系他!(希望大家帮忙up, 都有分,多谢了)谢谢大家!!!
  • 多谢各位支持,终于找到了实现GUID类似功能的方法,送分给各位关心过这个问题的朋友。
  • 配置过samba的朋友帮帮忙?多谢。
  •  
    本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术,将尽最大努力为读者提供更好的信息聚合和浏览方式。
    本站(WWW.)站内文章除注明原创外,均为转载、整理或搜集自网络。欢迎任何形式的转载,转载请注明出处。












  • 相关文章推荐
  • 关于Local接口和Remote接口!(请看过SUN的PetStore例子的朋友进来看看)!!!
  • 请网通的朋友,和沈阳的朋友进,有个兄弟需要帮忙!
  • 找啊,找朋友,找到一个好朋友。。。(linux后台开发)
  • 感谢Anubis(为朋友两肋插刀,为MM插朋友两刀!!) ( 五级(中级)),来拿分!!
  • 初学 java 的朋友来和我交朋友,我也是初学。我的 QQ 号是 33555085
  • 请Anubis(为朋友两肋插刀,为MM插朋友两刀!!) 进来领分
  • 做Linux的朋友请进来一起讨论,我是说正在Linux上工作的朋友:)
  • 这里有没有精通asp和精通jsp的朋友啊?我们叫个朋友怎么样?先送100分在说!
  • 各位朋友救命了~~~~~~真的,看见的朋友一定要进来
  • 装了Windows的朋友再装Redhat13的朋友请进
  • 朋友比较紧急的项目,懂Radius和AAA的朋友请进来看看
  • 圣诞节没有女友或没有男朋友的朋友们,在来年找个PMM或SGG!!!
  • 女朋友要过生日了,我在ubuntu下编了个小程序
  • 有没有最近想做个软件下载的站点的朋友
  • 希望能和这里的朋友认识一下!
  • 问一下,有朋友考了CNJD的吗??
  • 交个朋友怎样。
  • 我需要朋友们的帮忙
  • 有做过snmp agent开发的朋友吗?顶贴也给分
  • 快去呀!SCJP考试优惠!!(呵呵,给朋友做做广告)
  • 有没有在武汉学JAVA的和做开发的朋友!?


  • 站内导航:


    特别声明:169IT网站部分信息来自互联网,如果侵犯您的权利,请及时告知,本站将立即删除!

    ©2012-2021,,E-mail:www_#163.com(请将#改为@)

    浙ICP备11055608号-3