Acest cod este pentru a conecta baza de date SQL Micrososft cu instrucțiunea Callable folosind Java. Declarația callabilă, parametrul și adresa URL a driverului SQL se apelează din fișierul de proprietăți. Odată ce este conectat la baza de date, aceasta cuprinde toate valorile dintr-o anumită coloană bazată pe interogare. Puteți tipări outputul bazei de date SQL într-un fișier.
Conectați MS SQL cu fișierul de proprietăți și Declarația Callable
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;
public class DBConnect {
String privat dbValue;
public String getDbValue () {
returnați dbValue;
}
void public setDbValue (String dbValue) {
this.dbValue = dbValue;
}
statică publică statică callStoredProc () {
Intrare intrare = zero;
ResultSet rs = null;
PreparedStatement ps = null;
Conexiunea con = null;
Rezultatul șirului = null;
încerca {
String propPath = ". \ Src \ props \ db.properties"; // dosar de proprietate
input = fișierul FileInputStream (propPath) nou;
Proprietăți prop = Proprietăți noi ();
prop.load (intrare); // încărcați fișierul de proprietate
// obține valoarea proprietății
String dbDriver = (prop.getProperty ("dbDriver")); // driver din db.properties
String dbURL = (prop.getProperty ("dbURL"));
Class.forName (dbDriver);
con = DriverManager.getConnection (dbURL);
// Apel de procedură stocată
String stPro = (prop.getProperty ("SPSql1"));
ps = con.prepareStatement (stPro);
ps.setEscapeProcessing (true);
ps.setQueryTimeout (90); // timeout value
ps.setString (1, prop.getProperty ("VALUE1"));
ps.setString (2, prop.getProperty ("VALUE2"));
ps.setString (3, prop.getProperty ("VALUE3"));
rs = ps.executeQuery ();
rs.next ();
// Alegeți valoarea aleatorie din intervalul DB de 1-100
int random = (int) (Math.random () * 100 + 1);
int i = 0;
în timp ce (i <aleatoare) {
rs.next ();
i ++;
}
rezultatul = (rs.getString ("nume_rung")); //prop.getProperty("dbRow“)
prop.getProperty ( „dbRow“);
prop.getProperty ( „valoare2“);
} captură (IOException e) {
e.printStackTrace ();
} captură (ClassNotFoundException e) {
e.printStackTrace ();
} captură (SQLException e) {
e.printStackTrace ();
} in cele din urma {
încerca {
dacă (rs! = null)
input.close ();
dacă (rs! = null)
rs.close ();
dacă (ps! = null)
ps.close ();
dacă (con! = null)
con.close ();
} captură (Excepție e) {
e.printStackTrace ();
}
}
rezultatul retur;
}
}
// sfârșitul clasei
// dosar de proprietate
/*db.properties * /
dbDriver = com.microsoft.sqlserver.jdbc.SQLServerDriver
dbURL = jdbc: sqlserver: SERVER_URL; baze de date = NUME_BD; utilizator = USERNAME; parola = PAROLA
VALUE1 = aaa
VALUE2 = bbb
VALUE3 = ccc
SPSql1 = {call storeprecdurecall (?, ?, ?)}
dbRow = ROW_NAME
DB_USERNAME = uname
PAROLĂ_BD = parola
Acest exemplu particular, datele se iteră din tabel și se ia o valoare aleatorie din rezultat. În acest exemplu particular, am setat la o valoare 100 și ieșirea va alege o valoare aleatoare între 1-100 după rezultatul tabelului.