Αυτός ο κώδικας είναι να συνδέσετε τη βάση δεδομένων Micrososft SQL με την εντολή Callable χρησιμοποιώντας Java. Η παράμετρος Callable, η παράμετρος και η διεύθυνση URL του προγράμματος οδήγησης SQL καλούν από το αρχείο ιδιοτήτων. Μόλις συνδεθεί με τη βάση δεδομένων, συγκεντρώνει όλες τις τιμές σε μια συγκεκριμένη στήλη βάσει ερωτήματος. Μπορείτε να εκτυπώσετε την έξοδο βάσης δεδομένων SQL σε ένα αρχείο.
Συνδέστε το MS SQL με το αρχείο ιδιότητας και τη Δήλωση Εκκαθάρισης
import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;
import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;
import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;
import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;
import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;
import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;
import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;
import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;
import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;
import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;
δημόσια τάξη DBConnect {
ιδιωτικό String dbValue;
δημόσιο String getDbValue () {
επιστροφή dbValue;
}}
δημόσιο κενό setDbValue (String dbValue) {
this.dbValue = dbValue;
}}
δημόσια static String callStoredProc () {
Εισαγωγή εισόδουStream = null;
ΑποτέλεσμαSet rs = null;
PreparedStatement ps = null;
Σύνδεση con = null;
Αποτέλεσμα συμβολοσειράς = μηδέν.
προσπαθήστε {
String propPath = ". \ Src \ props \ db.properties"; // αρχείο αρχείου
είσοδος = νέα FileInputStream (propPath);
Ιδιότητες prop = νέες ιδιότητες ();
προφόρτωση (είσοδος); // φορτώστε το αρχείο ιδιοτήτων
// πάρτε την τιμή της ιδιοκτησίας
String dbDriver = (prop.getProperty ("dbDriver")); // driver από db.properties
Η συμβολοσειρά dbURL = (prop.getProperty ("dbURL"));
Class.forName (dbDriver);
con = DriverManager.getConnection (dbURL).
// Κλήση αποθηκευμένης διαδικασίας
String stPro = (prop.getProperty ("SPSql1")).
ps = con.prepareStatement (stPro).
ps.setEscapeProcessing (true);
ps.setQueryTimeout (90). // timeout τιμή
ps.setString (1, prop.getProperty ("VALUE1")).
ps.setString (2, prop.getProperty ("VALUE2")).
ps.setString (3, prop.getProperty ("VALUE3")).
rs = ps.executeQuery ();
rs.next ();
// Επιλέξτε τυχαία τιμή από την περιοχή DB 1-100
int τυχαία = (int) (Math.random () * 100 + 1);
int i = 0;
ενώ (i <τυχαία) {
rs.next ();
i ++;
}}
αποτέλεσμα = (rs.getString ("όνομα_γραμμής")); //prop.getProperty("dbRow ")
prop.getProperty ("dbRow");
prop.getProperty ("τιμή2");
} αλίευση (IOException e) {
e.printStackTrace ();
} catch (ClassNotFoundException ε) {
e.printStackTrace ();
} αλίευση (SQLException ε) {
e.printStackTrace ();
} τελικά {
προσπαθήστε {
αν (rs! = null)
input.close ();
αν (rs! = null)
rs.close ();
αν (ps! = null)
ps.close ();
αν (con! = null)
con.close ();
} catch (Εξαίρεση e) {
e.printStackTrace ();
}}
}}
αποτέλεσμα επιστροφής.
}}
}}
// τέλος της τάξης
// αρχείο αρχείου
/*db.properties * /
dbDriver = com.microsoft.sqlserver.jdbc.SQLServerDriver
dbURL = jdbc: sqlserver: SERVER_URL; βάση δεδομένων = DB_NAME; user = USERNAME; password = PASSWORD
VALUE1 = aaa
VALUE2 = bbb
VALUE3 = ccc
SPSql1 = {call storeprecdurecall (?, ?, ?)}
dbRow = όνομα γραμμής
DB_USERNAME = uname
DB_PASSWORD = κωδικός πρόσβασης
Αυτό το συγκεκριμένο παράδειγμα, τα δεδομένα μεταβάλλονται από τον πίνακα και λαμβάνουν τυχαία τιμή από το αποτέλεσμα. Σε αυτό το συγκεκριμένο παράδειγμα ορίσαμε μια τιμή 100 και η έξοδος θα πάρει μια τυχαία τιμή μεταξύ 1-100 από το αποτέλεσμα του πίνακα.
