Mega Code Archive
Blob and JDBC
<![CDATA[
/*
MySQL and Java Developer's Guide
Mark Matthews, Jim Cole, Joseph D. Gradecki
Publisher Wiley,
Published February 2003,
ISBN 0471269239
*/
import java.awt.Container;
import java.awt.FlowLayout;
import java.awt.Graphics2D;
import java.awt.GridLayout;
import java.awt.Image;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.awt.geom.AffineTransform;
import java.awt.image.BufferedImage;
import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.sql.Blob;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.Vector;
import javax.swing.ImageIcon;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JList;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
public class IDlookGetStream extends JFrame {
private JButton getAccountButton, updateAccountButton, insertAccountButton,
nextButton, previousButton, lastButton, firstButton;
private JList accountNumberList;
private JTextField accountIDText, nailFileText, thumbIDText;
private JTextArea errorText;
private Connection connection;
private Statement statement;
private ResultSet rs;
private ImageIcon icon = null;
private ImageIcon iconThumbnail = null;
JLabel photographLabel;
public IDlookGetStream() {
try {
Class.forName("com.mysql.jdbc.Driver").newInstance();
} catch (Exception e) {
System.err.println("Unable to find and load driver");
System.exit(1);
}
}
private void loadAccounts() {
Vector v = new Vector();
try {
rs = statement.executeQuery("SELECT * FROM thumbnail");
while (rs.next()) {
v.addElement(rs.getString("acc_id"));
}
} catch (SQLException e) {
displaySQLErrors(e);
}
accountNumberList.setListData(v);
}
private void buildGUI() {
Container c = getContentPane();
c.setLayout(new FlowLayout());
accountNumberList = new JList();
loadAccounts();
accountNumberList.setVisibleRowCount(2);
JScrollPane accountNumberListScrollPane = new JScrollPane(
accountNumberList);
//Do Get Account Button
getAccountButton = new JButton("Get Account");
getAccountButton.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
try {
rs.beforeFirst();
while (rs.next()) {
if (rs.getString("acc_id").equals(
accountNumberList.getSelectedValue()))
break;
}
if (!rs.isAfterLast()) {
accountIDText.setText(rs.getString("acc_id"));
thumbIDText.setText(rs.getString("thumb_id"));
Blob blob = rs.getBlob("pic");
int b;
InputStream bis = rs.getBinaryStream("pic");
FileOutputStream f = new FileOutputStream("pic.jpg");
while ((b = bis.read()) >= 0) {
f.write(b);
}
f.close();
bis.close();
icon = new ImageIcon(blob.getBytes(1L, (int) blob
.length()));
createThumbnail();
photographLabel.setIcon(iconThumbnail);
}
} catch (Exception selectException) {
displaySQLErrors(selectException);
}
}
});
//Do Update Account Button
updateAccountButton = new JButton("Update Account");
updateAccountButton.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
try {
byte[] bytes = new byte[50000];
FileInputStream fs = new FileInputStream(nailFileText
.getText());
BufferedInputStream bis = new BufferedInputStream(fs);
bis.read(bytes);
rs.updateBytes("thumbnail.pic", bytes);
rs.updateRow();
bis.close();
accountNumberList.removeAll();
loadAccounts();
} catch (SQLException insertException) {
displaySQLErrors(insertException);
} catch (Exception generalE) {
generalE.printStackTrace();
}
}
});
//Do insert Account Button
insertAccountButton = new JButton("Insert Account");
insertAccountButton.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent e) {
try {
byte[] bytes = new byte[50000];
FileInputStream fs = new FileInputStream(nailFileText
.getText());
BufferedInputStream bis = new BufferedInputStream(fs);
bis.read(bytes);
rs.moveToInsertRow();
rs.updateInt("thumb_id", Integer.parseInt(thumbIDText
.getText()));
rs.updateInt("acc_id", Integer.parseInt(accountIDText
.getText()));
rs.updateBytes("pic", bytes);
rs.updateObject("sysobject", null);
rs.updateTimestamp("ts", new Timestamp(0));
rs.updateTimestamp("act_ts", new Timestamp(
new java.util.Date().getTime()));
rs.insertRow();
bis.close();
accountNumberList.removeAll();
loadAccounts();
} catch (SQLException insertException) {
displaySQLErrors(insertException);
} catch (Exception generalE) {
generalE.printStackTrace();
}
}
});
photographLabel = new JLabel();
photographLabel.setHorizontalAlignment(JLabel.CENTER);
photographLabel.setVerticalAlignment(JLabel.CENTER);
photographLabel.setVerticalTextPosition(JLabel.CENTER);
photographLabel.setHorizontalTextPosition(JLabel.CENTER);
JPanel first = new JPanel(new GridLayout(4, 1));
first.add(accountNumberListScrollPane);
first.add(getAccountButton);
first.add(updateAccountButton);
first.add(insertAccountButton);
accountIDText = new JTextField(15);
thumbIDText = new JTextField(15);
errorText = new JTextArea(5, 15);
errorText.setEditable(false);
JPanel second = new JPanel();
second.setLayout(new GridLayout(2, 1));
second.add(thumbIDText);
second.add(accountIDText);
JPanel third = new JPanel();
third.add(new JScrollPane(errorText));
nailFileText = new JTextField(25);
c.add(first);
c.add(second);
c.add(third);
c.add(nailFileText);
c.add(photographLabel);
setSize(500, 500);
show();
}
public void connectToDB() {
try {
connection = DriverManager
.getConnection("jdbc:mysql://192.168.1.25/identification?user=spider&password=spider");
statement = connection.createStatement(
ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_UPDATABLE);
} catch (SQLException connectException) {
System.out.println(connectException.getMessage());
System.out.println(connectException.getSQLState());
System.out.println(connectException.getErrorCode());
System.exit(1);
}
}
private void displaySQLErrors(Exception e) {
errorText.append("Exception: " + e.getMessage() + "\n");
// errorText.append("State: " + e.getSQLState() + "\n");
// errorText.append("VendorError: " + e.getErrorCode() + "\n");
}
private void init() {
connectToDB();
}
private void createThumbnail() {
int maxDim = 350;
try {
Image inImage = icon.getImage();
double scale = (double) maxDim / (double) inImage.getHeight(null);
if (inImage.getWidth(null) > inImage.getHeight(null)) {
scale = (double) maxDim / (double) inImage.getWidth(null);
}
int scaledW = (int) (scale * inImage.getWidth(null));
int scaledH = (int) (scale * inImage.getHeight(null));
BufferedImage outImage = new BufferedImage(scaledW, scaledH,
BufferedImage.TYPE_INT_RGB);
AffineTransform tx = new AffineTransform();
if (scale < 1.0d) {
tx.scale(scale, scale);
}
Graphics2D g2d = outImage.createGraphics();
g2d.drawImage(inImage, tx, null);
g2d.dispose();
iconThumbnail = new ImageIcon(outImage);
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
IDlookGetStream id = new IDlookGetStream();
id.addWindowListener(new WindowAdapter() {
public void windowClosing(WindowEvent e) {
System.exit(0);
}
});
id.init();
id.buildGUI();
}
}
]]>