吴裕雄--天生自然JAVA数据库编程：处理大数据对象
生活随笔
收集整理的這篇文章主要介紹了
吴裕雄--天生自然JAVA数据库编程：处理大数据对象
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.SQLException ;
import java.sql.PreparedStatement ;
import java.io.File ;
import java.io.FileInputStream ;
import java.io.InputStream ;
public class ClobDemo01{
// 定義MySQL的數據庫驅動程序
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;
// 定義MySQL數據庫的連接地址
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;
// MySQL數據庫的連接用戶名
public static final String DBUSER = "root" ;
// MySQL數據庫的連接密碼
public static final String DBPASS = "mysqladmin" ;
public static void main(String args[]) throws Exception{ // 所有異常拋出
Connection conn = null ; // 數據庫連接
PreparedStatement pstmt = null ;
String name = "李興華" ; // 表示姓名
String sql = "INSERT INTO userclob(name,note) VALUES (?,?) " ;
Class.forName(DBDRIVER) ; // 加載驅動程序
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
pstmt = conn.prepareStatement(sql) ; // 創建PreapredStatement對象
File f = new File("d:" + File.separator + "mldn.txt") ;
InputStream input = null ;
input = new FileInputStream(f) ; // 通過輸入流讀取文件
pstmt.setString(1,name) ;
pstmt.setAsciiStream(2,input,(int)f.length()) ;
pstmt.executeUpdate() ;
conn.close() ; // 數據庫關閉
}
};
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.SQLException ;
import java.sql.PreparedStatement ;
import java.sql.ResultSet ;
import java.io.File ;
import java.io.FileInputStream ;
import java.io.InputStream ;
import java.util.Scanner ;
public class ClobDemo02{
// 定義MySQL的數據庫驅動程序
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;
// 定義MySQL數據庫的連接地址
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;
// MySQL數據庫的連接用戶名
public static final String DBUSER = "root" ;
// MySQL數據庫的連接密碼
public static final String DBPASS = "mysqladmin" ;
public static void main(String args[]) throws Exception{ // 所有異常拋出
Connection conn = null ; // 數據庫連接
PreparedStatement pstmt = null ;
ResultSet rs = null ;
int id = 1 ; // 讀取的編號 String sql = "SELECT name,note FROM userclob WHERE id=? " ;
Class.forName(DBDRIVER) ; // 加載驅動程序
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
pstmt = conn.prepareStatement(sql) ; // 創建PreapredStatement對象
pstmt.setInt(1,id) ;
rs = pstmt.executeQuery() ;
if(rs.next()){
String name = rs.getString(1) ;
StringBuffer note = new StringBuffer() ;
System.out.println("姓名：" + name) ;
InputStream input = rs.getAsciiStream(2) ;
Scanner scan = new Scanner(input) ; // 使用Scanner類讀取內容
scan.useDelimiter("\r\n") ; // 將文件換行作為分割符
while(scan.hasNext()){
note.append(scan.next()).append("\n") ;
}
System.out.println("內容：" + note) ;
input.close() ;
}
rs.close() ;
pstmt.close() ;
conn.close() ; // 數據庫關閉
}
};
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.SQLException ;
import java.sql.PreparedStatement ;
import java.sql.Clob ;
import java.sql.ResultSet ;
public class ClobDemo03{
// 定義MySQL的數據庫驅動程序
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;
// 定義MySQL數據庫的連接地址
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;
// MySQL數據庫的連接用戶名
public static final String DBUSER = "root" ;
// MySQL數據庫的連接密碼
public static final String DBPASS = "mysqladmin" ;
public static void main(String args[]) throws Exception{ // 所有異常拋出
Connection conn = null ; // 數據庫連接
PreparedStatement pstmt = null ;
ResultSet rs = null ;
int id = 1 ; // 讀取的編號 String sql = "SELECT name,note FROM userclob WHERE id=? " ;
Class.forName(DBDRIVER) ; // 加載驅動程序
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
pstmt = conn.prepareStatement(sql) ; // 創建PreapredStatement對象
pstmt.setInt(1,id) ;
rs = pstmt.executeQuery() ;
if(rs.next()){
String name = rs.getString(1) ;
System.out.println("姓名：" + name) ;
Clob c = rs.getClob(2) ;
String note = c.getSubString(1,(int)c.length()) ;
System.out.println("內容：" + note ) ;
c.truncate(100) ; // 只能讀100個內容
System.out.println("部分讀取內容：" + c.getSubString(1,(int)c.length())) ;
}
rs.close() ;
pstmt.close() ;
conn.close() ; // 數據庫關閉
}
};
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.SQLException ;
import java.sql.PreparedStatement ;
import java.io.File ;
import java.io.FileInputStream ;
import java.io.InputStream ;
public class BlobDemo01{
// 定義MySQL的數據庫驅動程序
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;
// 定義MySQL數據庫的連接地址
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;
// MySQL數據庫的連接用戶名
public static final String DBUSER = "root" ;
// MySQL數據庫的連接密碼
public static final String DBPASS = "mysqladmin" ;
public static void main(String args[]) throws Exception{ // 所有異常拋出
Connection conn = null ; // 數據庫連接
PreparedStatement pstmt = null ;
String name = "李興華" ;
String sql = "INSERT INTO userblob(name,photo) VALUES (?,?) " ;
Class.forName(DBDRIVER) ; // 加載驅動程序
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
pstmt = conn.prepareStatement(sql) ;
File f = new File("d:" + File.separator + "mldn.gif") ; // 圖片文件
InputStream input = null ;
input = new FileInputStream(f) ;
pstmt.setString(1,name) ; // 設置第一個“?”的內容
pstmt.setBinaryStream(2,input,(int)f.length()) ; // 設置輸入流
pstmt.executeUpdate() ; // 更新數據庫
pstmt.close() ;
conn.close() ; // 數據庫關閉
}
};
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.SQLException ;
import java.sql.PreparedStatement ;
import java.io.File ;
import java.io.FileOutputStream ;
import java.sql.ResultSet ;
import java.io.InputStream ;
import java.io.InputStream ;
import java.io.OutputStream ;
public class BlobDemo02{
// 定義MySQL的數據庫驅動程序
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;
// 定義MySQL數據庫的連接地址
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;
// MySQL數據庫的連接用戶名
public static final String DBUSER = "root" ;
// MySQL數據庫的連接密碼
public static final String DBPASS = "mysqladmin" ;
public static void main(String args[]) throws Exception{ // 所有異常拋出
Connection conn = null ; // 數據庫連接
PreparedStatement pstmt = null ;
ResultSet rs = null ;
int id = 1 ;
String sql = "SELECT name,photo FROM userblob WHERE id=?" ;
Class.forName(DBDRIVER) ; // 加載驅動程序
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
pstmt = conn.prepareStatement(sql) ;
pstmt.setInt(1,id) ;
rs = pstmt.executeQuery() ; // 執行查詢
if(rs.next()){
String name = rs.getString(1) ;
System.out.println("姓名：" + name) ;
InputStream input = rs.getBinaryStream(2) ;
File f = new File("d:" + File.separator + "loadmldn.gif") ; // 圖片文件
OutputStream out = null ;
out = new FileOutputStream(f) ;
int temp = 0 ;
while((temp=input.read())!=-1){ // 邊讀邊寫
out.write(temp) ;
}
input.close() ;
out.close() ;
}
pstmt.close() ;
conn.close() ; // 數據庫關閉
}
};
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.SQLException ;
import java.sql.PreparedStatement ;
import java.sql.Blob ;
import java.sql.ResultSet ;
import java.io.File ;
import java.io.FileOutputStream ;
import java.io.InputStream ;
import java.io.InputStream ;
import java.io.OutputStream ; public class BlobDemo03{
// 定義MySQL的數據庫驅動程序
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;
// 定義MySQL數據庫的連接地址
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;
// MySQL數據庫的連接用戶名
public static final String DBUSER = "root" ;
// MySQL數據庫的連接密碼
public static final String DBPASS = "mysqladmin" ;
public static void main(String args[]) throws Exception{ // 所有異常拋出
Connection conn = null ; // 數據庫連接
PreparedStatement pstmt = null ;
ResultSet rs = null ;
int id = 1 ;
String sql = "SELECT name,photo FROM userblob WHERE id=?" ;
Class.forName(DBDRIVER) ; // 加載驅動程序
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
pstmt = conn.prepareStatement(sql) ;
pstmt.setInt(1,id) ;
rs = pstmt.executeQuery() ; // 執行查詢
if(rs.next()){
String name = rs.getString(1) ;
System.out.println("姓名：" + name) ;
Blob b = rs.getBlob(2) ;
File f = new File("d:" + File.separator + "loadmldn.gif") ; // 圖片文件
OutputStream out = null ;
out = new FileOutputStream(f) ;
out.write(b.getBytes(1,(int)b.length())) ;
out.close() ;
}
pstmt.close() ;
conn.close() ; // 數據庫關閉
}
};
總結
以上是生活随笔為你收集整理的吴裕雄--天生自然JAVA数据库编程：处理大数据对象的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： acm公选课笔记 2020.3.31
- 下一篇： 飞桨抠图直播2020.4.1