為大家精心準(zhǔn)備了上千本技術(shù)書(shū)籍,微信搜索關(guān)注公眾號(hào):【zhulin1028】,或者掃描以下二維碼,回復(fù)【電子書(shū)】即可免費(fèi)獲取。
?目錄
import java.sql.*;
public class DatabaseTest {
???????? public static void main(String args[]) {
?????????????????? Connection con;
?????????????????? Statement stmt;
?????????????????? ResultSet rs;
?????????????????? try {
??????????????????????????? Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
?????????????????? } catch (ClassNotFoundException e) {
??????????????????????????? System.out.println("" + e);
?????????????????? }
?????????????????? try {
??????????????????????????? con = DriverManager.getConnection("jdbc:odbc:library", "book", "123");
??????????????????????????? stmt = con.createStatement();
??????????????????????????? rs = stmt.executeQuery("SELECT * FROM bookdata");
??????????????????????????? while (rs.next()) {
???????????????????????????????????? String isbn = rs.getString("isbn");
???????????????????????????????????? String name = rs.getString("name");
???????????????????????????????????? String authors = rs.getString(5);
???????????????????????????????????? float price = rs.getInt("price");
???????????????????????????????????? int pages = rs.getInt("pages");
???????????????????????????????????? System.out.print("書(shū)號(hào):" + isbn);
???????????????????????????????????? System.out.print("? 書(shū)名:" + name);
???????????????????????????????????? System.out.print("? 作者:" + authors);
???????????????????????????????????? System.out.print("? 定價(jià):" + price);
???????????????????????????????????? System.out.println("? 頁(yè)數(shù):" + pages);
??????????????????????????? }
??????????????????????????? rs.close();
??????????????????????????? stmt.close();
??????????????????????????? con.close();
?????????????????? } catch (SQLException e) {
??????????????????????????? System.out.println(e);
?????????????????? }
???????? }
}
import java.sql.*;
public class DatabaseTest {
???????? public static void main(String args[]) {
?????????????????? Connection con;
?????????????????? Statement stmt;
?????????????????? ResultSet rs;
?????????????????? try {
??????????????????????????? Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
?????????????????? } catch (ClassNotFoundException e) {
?????????????????? }
?????????????????? try {
??????????????????????????? con = DriverManager.getConnection("jdbc:odbc:library", "book", "123");
??????????????????????????? stmt = con.createStatement();
??????????????????????????? rs = stmt.executeQuery("SELECT name,price FROM bookdata WHERE price >= 30");
??????????????????????????? while (rs.next()) {
???????????????????????????????????? String name = rs.getString(1);
???????????????????????????????????? double price = rs.getInt("price");
???????????????????????????????????? System.out.print("? 書(shū)名:" + name);
???????????????????????????????????? System.out.println("? 定價(jià):" + price);
??????????????????????????? }
??????????????????????????? rs.close();
??????????????????????????? stmt.close();
??????????????????????????? con.close();
?????????????????? } catch (SQLException e) {
??????????????????????????? System.out.println(e);
?????????????????? }
???????? }
}
import java.sql.*;
public class DatabaseTest {
???????? public static void main(String args[]) {
?????????????????? Connection con;
?????????????????? Statement stat;
?????????????????? ResultSet rs;
?????????????????? try {
??????????????????????????? Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
?????????????????? } catch (ClassNotFoundException e) {
??????????????????????????? System.out.println("" + e);
?????????????????? }
?????????????????? try {
??????????????????????????? con = DriverManager.getConnection("jdbc:odbc:library", "book", "123");
??????????????????????????? stat = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
?????????????????????????????????????????????? ResultSet.CONCUR_READ_ONLY);
??????????????????????????? rs = stat.executeQuery("SELECT name,pages FROM bookdata");
??????????????????????????? rs.last();
??????????????????????????? int number = rs.getRow();
??????????????????????????? System.out.println("該表共有" + number + "條記錄");
??????????????????????????? rs.afterLast();
??????????????????????????? while (rs.previous()) {
???????????????????????????????????? String name = rs.getString("name");
???????????????????????????????????? int pages = rs.getInt("pages");
???????????????????????????????????? System.out.print("? 書(shū)名:" + name);
???????????????????????????????????? System.out.println("? 頁(yè)數(shù):" + pages);
??????????????????????????? }
??????????????????????????? System.out.println("單獨(dú)輸出第5條記錄:");
??????????????????????????? rs.absolute(5);
??????????????????????????? String name = rs.getString("name");
??????????????????????????? int pages = rs.getInt("pages");
??????????????????????????? System.out.print("? 書(shū)名:" + name);
??????????????????????????? System.out.println("? 頁(yè)數(shù):" + pages);
??????????????????????????? rs.close();
??????????????????????????? stat.close();
??????????????????????????? con.close();
?????????????????? } catch (SQLException e) {
??????????????????????????? System.out.println(e);
?????????????????? }
???????? }
}
import java.sql.*;
public class DatabaseTest {
???????? public static void main(String args[]) {
?????????????????? Connection con;
?????????????????? Statement sql;
?????????????????? ResultSet rs;
?????????????????? try {
??????????????????????????? Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
?????????????????? } catch (ClassNotFoundException e) {
?????????????????? }
?????????????????? try {
??????????????????????????? con = DriverManager.getConnection("jdbc:odbc:library", "book", "123");
??????????????????????????? sql = con.createStatement();
??????????????????????????? String condition = "SELECT name, pages FROM chengjibiao ORDER BY pages";
??????????????????????????? rs = sql.executeQuery(condition);
??????????????????????????? while (rs.next()) {
???????????????????????????????????? String name = rs.getString(1);
???????????????????????????????????? int pages = rs.getInt(2);
???????????????????????????????????? System.out.print("? 姓名:" + name);
???????????????????????????????????? System.out.println("? 頁(yè)數(shù):" + pages);
??????????????????????????? }
??????????????????????????? con.close();
?????????????????? } catch (SQLException e) {
??????????????????????????? System.out.println(e);
?????????????????? }
???????? }
}
import java.sql.*;
public class DatabaseTest {
???????? public static void main(String args[]) {
?????????????????? Connection con;
?????????????????? Statement sql;
?????????????????? ResultSet rs;
?????????????????? try {
??????????????????????????? Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
?????????????????? } catch (ClassNotFoundException e) {
?????????????????? }
?????????????????? try {
??????????????????????????? con = DriverManager.getConnection("jdbc:odbc:library", "book",
?????????????????????????????????????????????? "123");
??????????????????????????? sql = con.createStatement();
??????????????????????????? rs = sql.executeQuery("SELECT name,price FROM bookdata WHERE name LIKE '%java%' ");
??????????????????????????? while (rs.next()) {
???????????????????????????????????? String name = rs.getString(1);
???????????????????????????????????? double price = rs.getInt(2);
???????????????????????????????????? System.out.print("? 書(shū)名:" + name);
???????????????????????????????????? System.out.println("? 定價(jià):" + price);
??????????????????????????? }
??????????????????????????? rs.close();
??????????????????????????? sql.close();
??????????????????????????? con.close();
?????????????????? } catch (SQLException e) {
??????????????????????????? System.out.println(e);
?????????????????? }
???????? }
}
import java.sql.*;
import java.util.LinkedList;
public class DatabaseTest {
???????? public static void main(String args[]) {
?????????????????? LinkedList list = new LinkedList();
?????????????????? Connection con;
?????????????????? Statement sql;
?????????????????? ResultSet rs;
?????????????????? try {
??????????????????????????? Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
?????????????????? } catch (ClassNotFoundException e) {
?????????????????? }
?????????????????? try {
??????????????????????????? con = DriverManager.getConnection("jdbc:odbc:library", "book", "123");
??????????????????????????? sql = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
?????????????????????????????????????????????? ResultSet.CONCUR_READ_ONLY);
??????????????????????????? rs = sql.executeQuery("SELECT name,pages FROM bookdata");
??????????????????????????? rs.last();
??????????????????????????? int lownumber = rs.getRow();
??????????????????????????? int number = lownumber;
??????????????????????????? for (int i = 1; i <= number; i++) {
???????????????????????????????????? list.add(new Integer(i));
??????????????????????????? }
??????????????????????????? double sum = 0;
??????????????????????????? int k = 4;
??????????????????????????? int 抽取數(shù)目 = k;
??????????????????????????? while (k > 0) {
???????????????????????????????????? int i = (int) (Math.random() * list.size());
???????????????????????????????????? int index = ((Integer) list.get(i)).intValue();
???????????????????????????????????? rs.absolute(index);
???????????????????????????????????? System.out.print("書(shū)名:" + rs.getString(1));
???????????????????????????????????? System.out.println("頁(yè)數(shù):" + rs.getString(2));
???????????????????????????????????? int math = rs.getInt("pages");
???????????????????????????????????? sum = sum + math;
???????????????????????????????????? k--;
???????????????????????????????????? list.remove(i);
??????????????????????????? }
??????????????????????????? System.out.println("抽樣的圖書(shū)平均頁(yè)數(shù):" + sum / 抽取數(shù)目);
??????????????????????????? con.close();
?????????????????? } catch (SQLException e) {
??????????????????????????? System.out.println(e);
?????????????????? }
???????? }
}
import java.sql.*;
public class DatabaseTest {
???????? public static void main(String args[]) {
?????????????????? Connection con;
?????????????????? Statement stmt;
?????????????????? ResultSet rs;
?????????????????? try {
??????????????????????????? Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
?????????????????? } catch (ClassNotFoundException e) {
?????????????????? }
?????????????????? try {
??????????????????????????? con = DriverManager.getConnection("jdbc:odbc:library", "book",
?????????????????????????????????????????????? "123");
??????????????????????????? stmt = con.createStatement();
??????????????????????????? int pages = 299;
??????????????????????????? String isbn = "9877811234169", name, authors, publisher;
??????????????????????????? String updateStr = "UPDATE bookdata SET pages =" + pages
?????????????????????????????????????????????? + " WHERE isbn = " + "'" + isbn + "'";
??????????????????????????? pages = 400;
??????????????????????????? float price = 45.8f;
??????????????????????????? isbn = "9877811239999";
??????????????????????????? name = "Java高級(jí)數(shù)據(jù)庫(kù)編程";
??????????????????????????? authors = "張三,李四,王五";
??????????????????????????? publisher = "藍(lán)天出版社";
??????????????????????????? String value = "(" + "'" + isbn + "', '" + name + "', '" + authors
?????????????????????????????????????????????? + "', '" + publisher + "', " + pages + "," + price + ")";
??????????????????????????? String insertStr = "INSERT INTO bookdata(isbn, name, authors, publisher, pages, price) VALUES " + value;
??????????????????????????? String delStr = "DELETE FROM bookdata WHERE isbn = '9877811239999' ";
??????????????????????????? stmt.executeUpdate(updateStr);
??????????????????????????? stmt.executeUpdate(insertStr);
??????????????????????????? stmt.executeUpdate(delStr);
??????????????????????????? rs = stmt.executeQuery("SELECT * FROM bookdata");
??????????????????????????? while (rs.next()) {
???????????????????????????????????? isbn = rs.getString("isbn");
???????????????????????????????????? name = rs.getString("name");
??????????????????????????? ???????? authors = rs.getString(5);
???????????????????????????????????? publisher = rs.getString("publisher");
???????????????????????????????????? pages = rs.getInt("pages");
???????????????????????????????????? price = rs.getFloat("price");
???????????????????????????????????? System.out.print("書(shū)號(hào):" + isbn);
???????????????????????????????????? System.out.print("? 書(shū)名:" + name);
???????????????????????????????????? System.out.print("? 作者:" + authors);
???????????????????????????????????? System.out.print("? 作者:" + publisher);
???????????????????????????????????? System.out.print("? 頁(yè)數(shù):" + pages);
???????????????????????????????????? System.out.println("? 定價(jià):" + price);
??????????????????????????? }
??????????????????????????? rs.close();
??????????????????????????? stmt.close();
??????????????????????????? con.close();
?????????????????? } catch (SQLException e) {
??????????????????????????? System.out.println(e);
?????????????????? }
???????? }
}
import java.sql.*;
public class DatabaseTest {
???????? public static void main(String args[]) {
?????????????????? Connection con;
?????????????????? PreparedStatement pstmt;
?????????????????? ResultSet rs;
?????????????????? try {
??????????????????????????? Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
?????????????????? } catch (ClassNotFoundException e) {
??????????????????????????? System.out.println("" + e);
?????????????????? }
?????????????????? try {
??????????????????????????? con = DriverManager.getConnection("jdbc:odbc:library", "book", "123");
??????????????????????????? pstmt = con.prepareStatement("SELECT isbn, price FROM bookdata"); // 預(yù)處理語(yǔ)句
??????????????????????????? rs = pstmt.executeQuery();
??????????????????????????? while (rs.next()) {
???????????????????????????????????? String isbn = rs.getString(1);
???????????????????????????????????? float price = rs.getFloat(2);
???????????????????????????????????? System.out.print("書(shū)號(hào):" + isbn);
???????????????????????????????????? System.out.println("? 定價(jià):" + price);
??????????????????????????? }
??????????????????????????? con.close();
?????????????????? } catch (SQLException e) {
??????????????????????????? System.out.println(e);
?????????????????? }
???????? }
}
import java.sql.*;
public class DatabaseTest {
???????? public static void main(String args[]) {
?????????????????? Connection con;
?????????????????? PreparedStatement pstmt1, pstmt2, pstmt3;
?????????????????? ResultSet rs;
?????????????????? try {
??????????????????????????? Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
?????????????????? } catch (ClassNotFoundException e) {
??????????????????????????? System.out.println("" + e);
?????????????????? }
?????????????????? try {
??????????????????????????? con = DriverManager.getConnection("jdbc:odbc:library", "book", "123");
??????????????????????????? pstmt1 = con.prepareStatement("UPDATE bookdata SET price = ? WHERE id= ? ");
??????????????????????????? pstmt1.setFloat(1, 55.5f);
??????????????????????????? pstmt1.setInt(2, 1);
??????????????????????????? pstmt1.executeUpdate();
??????????????????????????? pstmt1.setInt(1, 2);
??????????????????????????? pstmt1.setFloat(2, 66.6f);
??????????????????????????? pstmt1.executeUpdate();
??????????????????????????? pstmt2 = con.prepareStatement("INSERT INTO bookdata(isbn, name, pages, price) VALUES (?,?,?,?)");
??????????????????????????? pstmt2.setString(1, "20038881111");
??????????????????????????? pstmt2.setString(2, "Oracle數(shù)據(jù)庫(kù)使用指南");
??????????????????????????? pstmt2.setInt(3, 300);
??????????????????????????? pstmt2.setFloat(4, 77.7f);
??????????????????????????? pstmt2.executeUpdate();
??????????????????????????? pstmt3 = con.prepareStatement("SELECT name, pages, price FROM bookdata WHERE pages <= ? AND price >= ? ");
??????????????????????????? pstmt3.setInt(1, 400);
??????????????????????????? pstmt3.setFloat(2, 50f);
??????????????????????????? System.out.println("3.............");
??????????????????????????? rs = pstmt3.executeQuery();
??????????????????????????? while (rs.next()) {
???????????????????????????????????? System.out.print("書(shū)名:" + rs.getString(1));
???????????????????????????????????? System.out.print("? 頁(yè)數(shù):" + rs.getInt(2));
???????????????????????????????????? System.out.println("? 定價(jià):" + rs.getFloat(3));
??????????????????????????? }
??????????????????????????? con.close();
?????????????????? } catch (SQLException e) {
??????????????????????????? System.out.println(e);
?????????????????? }
???????? }
}
(1) 客戶(hù)端程序
import java.net.*;
import java.io.*;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
public class Client
{
?public static void main(String args[])
? {? new QueryClient();
? }
}
class QueryClient extends Frame
implements Runnable,ActionListener
{? Button connection,send;
?? TextField inputText;
?? TextArea showResult;
?? Socket socket=null;
?? DataInputStream in=null;
?? DataOutputStream out=null;
?? Thread thread;
?? QueryClient()
?? {? socket=new Socket();
????? Panel p=new Panel();
????? connection=new Button("連接服務(wù)器");
????? send=new Button("發(fā)送");
????? send.setEnabled(false);
????? inputText=new TextField(8);
????? showResult=new TextArea(6,42);
????? p.add(connection);
????? p.add(new Label("輸入學(xué)號(hào)"));
????? p.add(inputText);
????? p.add(send);
????? add(p,BorderLayout.NORTH);
????? add(showResult,BorderLayout.CENTER);
????? connection.addActionListener(this);
????? send.addActionListener(this);
????? thread=new Thread(this);
????? setBounds(10,30,350,400);
????? setVisible(true);
????? validate();
????? addWindowListener(new WindowAdapter()
?????????????????? {? public void windowClosing(WindowEvent e)
??????????????????????????? {? System.exit(0);
??????????????????????????? }
?????????????????? });
?? }
?? public void actionPerformed(ActionEvent e)
?? { if(e.getSource()==connection)
????? {? try?
???????? { if(socket.isConnected())
???? ?????????{}
?????????? else
????????????? { InetAddress? address=InetAddress.getByName("127.0.0.1");
??????????????? InetSocketAddress socketAddress=new InetSocketAddress(address,4331);
??????????????? socket.connect(socketAddress);
??????????????? in =new DataInputStream(socket.getInputStream());
??????????????? out = new DataOutputStream(socket.getOutputStream());
??????????????? send.setEnabled(true);
??????????????? thread.start();
?????????????? }
???????? }
???????? catch (IOException ee){}
????? }
???? if(e.getSource()==send)
????? {? String s=inputText.getText();
???????? if(s!=null)
?????????? {? try { out.writeUTF(s);
????????????????? }
????????????? catch(IOException e1){}
?????????? }??????????????
????? }
?? }
?? public void run()
?? {? String s=null;
????? while(true)
?????? {??? try{? s=in.readUTF();
????????????????? showResult.append("\n"+s);
?????????????? }
?????????? catch(IOException e)
?????????????? {? showResult.setText("與服務(wù)器已斷開(kāi)");
????????????????????? break;
?????????????? }? ?
?????? }
? }
}
(2) 服務(wù)器端程序
import java.io.*;
import java.net.*;
import java.util.*;
import java.sql.*;
public class Server
{? public static void main(String args[])
?? {? Connection con;
????? PreparedStatement sql=null;
????? ResultSet rs;
????? try{? Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
???????? }
????? catch(ClassNotFoundException e){}
????? try{? con=DriverManager.getConnection("jdbc:odbc:sun","gxy","123");
??????????? sql=con.prepareStatement("SELECT * FROM chengjibiao WHERE number = ? ");
???????? }
????? catch(SQLException e){}
????? ServerSocket server=null;
????? Server_thread thread;
????? Socket you=null;
????? while(true)
?????? {? try{? server=new ServerSocket(4331);
???????????? }
????????? catch(IOException e1)
???? ????????{? System.out.println("正在監(jiān)聽(tīng)");
???????????? }
????????? try{? System.out.println(" 等待客戶(hù)呼叫");
??????????????? you=server.accept();
??????????????? System.out.println("客戶(hù)的地址:"+you.getInetAddress());
???????????? }
???????? catch(IOException e)
??? ?????????{? System.out.println("正在等待客戶(hù)");
???????????? }
???????? if(you!=null)
???????????? {? new Server_thread(you,sql).start();??
???????????? }
?????? }
?? }
}
class Server_thread extends Thread
{? Socket socket;
?? DataOutputStream out=null;
?? DataInputStream? in=null;
?? PreparedStatement sql;
?? boolean boo=false;
?? Server_thread(Socket t, PreparedStatement sql)
?? {? socket=t;
????? this.sql=sql;
????? try {? out=new DataOutputStream(socket.getOutputStream());
???????????? in=new DataInputStream(socket.getInputStream());
????????? }
????? catch(IOException e){}
?? }?
?? public void run()???????
?? { while(true)
???? {try{
????????? String num=in.readUTF();
????????? boo=false;
????????? sql.setString(1,num);
????????? ResultSet rs=sql.executeQuery() ;
????????? while(rs.next())
??????????? { boo=true;
????????????? String number=rs.getString(1);
????????????? String name=rs.getString(2);
????????????? String date=rs.getString(3);
????????????? int math=rs.getInt(4);
????????????? int english=rs.getInt(5);?
????????????? out.writeUTF("學(xué)號(hào):"+number+" 姓名:"+name+" 出生:"+date
??????????????????????? +" 數(shù)學(xué):"+math+" 英語(yǔ)"+english);
??????????? }
????????? if(boo==false)
??????????? { out.writeUTF("沒(méi)有該學(xué)號(hào)!");
??????????? }
???????? }
????? catch (Exception e)
???????? {? System.out.println("客戶(hù)離開(kāi)"+e);
?????????????? return;
???????? }
???? }
?? }
}
聯(lián)系客服