SQL 注入开放与修复
开发：
SQL 注入是一种数据库攻击手段。攻击者通过向应用程序提交恶意代码来改变原 SQL 语句的含义，
进而执行任意 SQL 命令，达到入侵数据库乃至操作系统的目的。
例如：下面代码片段中，动态构造并执行了一个 SQL 查询来认证用户。
public void doPrivilegedAction( String username, char[] password) throws SQLException {
Connection connection = getConnection();
if (connection == null) {
// handle error
}
try {
String pwd = hashPassword(password);
String sqlString = "SELECT * FROM db_user WHERE username = '" + username + "' AND password
= '" + pwd + "'";
Statement stmt = connection.createStatement();
ResultSet rs = stmt.executeQuery(sqlString);
if (!rs.next()) {
throw new SecurityException( "User name or password incorrect");
}
// Authenticated; proceed
} finally {
try {
connection.close();
} catch (SQLException x) {
// forward to handler
}
}
}
如果攻击者能够替代 username 和 password 中的任意字符串，它们可以使用下面的关于 username 的字
符串进行 SQL 注入。
validuser' OR '1'='1
当其注入到命令时，命令就会变成：
SELECT * FROM db_user WHERE username=’validuser' OR '1'='1' AND password=’’
同样，攻击者可以为 password 提供如下字符串。
' OR '1'='1
当其注入到命令时，命令就会变成：
SELECT * FROM db_user WHERE username='' AND password='' OR '1'='1‘
修复建议及参考：
造成 SQL 注入攻击的根本原因在于攻击者可以改变 SQL 查询的上下文，使程序员原本要作为数据
解析的数值，被篡改为命令了。防止 SQL 注入的方法如下：
（ 1 ）正确使用参数化 API 进行 SQL 查询。
（ 2 ）如果构造 SQL 指令时需要动态加入约束条件，可以通过创建一份合法字符串列表，使其对应于可
能要加入到 SQL 指令中的不同元素，来避免 SQL 注入攻击。
例 如 ： 以 下 代 码 片 段 使 用
java.sql.PreparedStatement
代 替 java.sql.Statement ， 在
java.sql.PreparedStatement 类中可以对输入字符串进行转义，如果使用正确的话，可以防止 SQL 注入。
public void doPrivilegedAction(String username, char[] password) throws SQLException {
Connection connection = getConnection();
if (connection == null) {
// Handle error
}
try {
String pwd = hashPassword(password);
// Ensure that the length of user name is legitimate
if ((username.length() > 8) {
// Handle error
}
String sqlString = "select * from db_user where username=? and password=?";
PreparedStatement stmt = connection.prepareStatement(sqlString);
stmt.setString(1, username);
stmt.setString(2, pwd);
ResultSet rs = stmt.executeQuery();
if (!rs.next()) {
throw new SecurityException("User name or password incorrect");
}
// Authenticated, proceed
} finally {
try {
connection.close();
} catch (SQLException x) {
// forward to handler
}
}
}