1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183
| package conn;
import java.util.*;
import java.sql.*;
public class Trame
{String s;
Connection conn;
Statement stmt;
String Tab[] = new String[10]; //tableau des valeurs
Trame() {}
Trame(String s){this.s=s;}
public void decouper(String sep) throws SQLException{
int i=0;
StringTokenizer st =new StringTokenizer(this.s,sep);//3 séparateurs ; , et blanc
while (st.hasMoreTokens()){ //boucle de lecture
Tab[i]=st.nextToken();
i++;
}
if (Tab[0].equals("$IIMWV")&&Tab[4].equals("A<CR><LF>"))
{
stmt = conn.createStatement();
stmt.executeUpdate("INSERT INTO trame VALUES (Tab[0], Tab[1], Tab[2])");
System.out.println("trame complète");
}
else System.out.println("trame incomplete");
}
private void printInfo(Connection c) throws Exception
{
// Get meta-data about the database
DatabaseMetaData info = c.getMetaData();
System.out.println("\nConnected to :\t" + info.getURL());
System.out.println("Driver :\t" + info.getDriverName());
System.out.println("Version :\t" + info.getDriverVersion());
}
/* Print stdout all pending SQLWarning warnings
*/
private boolean checkForSQLWarnings(SQLWarning w)
throws SQLException
{
boolean warning = false;
if(w != null) {
warning = true;
System.out.println("\n**** Warning ****\n");
while(w != null) {
System.out.println("SQLState: " + w.getSQLState());
System.out.println("Message: " + w.getMessage());
System.out.println("Vendor: " + w.getErrorCode());
System.out.println("");
w = w.getNextWarning();
}
}
return warning;
}
/* Print stderr all pending SQLException exceptions
*/
private void printSQLErrors(SQLException e)
{
while(e != null) {
System.err.println("SQLState: " + e.getSQLState());
System.err.println("Message: " + e.getMessage());
System.err.println("Vendor: " + e.getErrorCode());
System.err.println("");
e = e.getNextException();
}
}
public void loadDriverAndConnect()
throws Exception
{
try {
// Load the jdbc driver for MySQL
Class.forName("com.mysql.jdbc.Driver");
// Get a connection to the database source using Thin JDBC driver
String url = "jdbc:mysql://localhost:3306/test";
conn = DriverManager.getConnection(url, "root", "khawla");
// Print stdout warning messages if necessary
checkForSQLWarnings(conn.getWarnings());
// Print stdout info messages
printInfo(conn);
}
catch(SQLException e) {
System.err.println("\n*** SQLException caught in LoadDriver()");
printSQLErrors(e);
throw e;
}
catch(Exception e) {
// This exception is caught if JDBC driver used cannot be loaded
System.err.println("\n*** Exception caught in LoadDriver()");
throw e;
}
}
/**
* Close the connection to the data base source
*/
public void close() throws Exception
{
try {
conn.close();
System.out.println("Test : Disconnecting ...");
}
catch(Exception e) {
System.err.println("\n*** Exception caught in close()");
throw e;
}
}
public void createTablesAndInit() throws Exception
{
stmt = conn.createStatement();
stmt.executeUpdate("INSERT INTO trame VALUES ('Tab[0]', 'Tab[0]', 'Tab[0]')");
}
public void selectData() throws Exception
{
ResultSet rs = null;
String requete = "SELECT nom, pos FROM trame";
try{
rs = stmt.executeQuery(requete);
}
catch(SQLException e){
System.err.println("Erreur dans selectData() - 1");
throw e;
}
while(rs.next()){
String s = rs.getString("nom");
String n = rs.getString("pos");
System.out.println(s + " " + n);
}
}
public static void main (String argv [])
{ Trame T= new Trame("$IIMWV,R,000.30,N,A<CR><LF>");
try {
T.loadDriverAndConnect();
} catch (Exception e) {
e.printStackTrace();
}
try {
T.decouper(",");
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* @param args
*/ |
Partager